数据概览
0
粉丝
1
关注
2
获赞
0
被收藏
0
被评论
17
浏览
0
回答
0
被采纳
0.0%
采纳率
3
信誉
0
积分
0
任务收益
背景 - Kafka 3.4(3 broker KRaft),topic "risk-eval-result" 64 分区,消费组 8 实例(每实例 8 分区) - 消费逻辑固定三步:"consumer.poll()" → 调外部风控引擎
«先抛个我想听大家拍砖的问题:你们线上 "auto.offset.reset" 到底设的什么值?设了 "earliest" 就敢拍胸脯说"新消费组一定全量重放"吗? 我们去年就栽在这儿——设了 "earliest" 依然跳过了 6 天历史,
«先抛一个我想听大家拍砖的问题:你把 producer 设成 "acks=all",是不是就真觉得"我这一条消息绝不会丢"了? 我去年在压测环境里被它打了一次脸,今天把账算清楚。» 一、现象与背景:一次"看起来万无一失"的丢消息 去年 10