标签频道
消费位点
该标签下的文章、提问与讨论帖。
背景 我负责订单履约链路,Kafka 3.5(KRaft,3 broker),topic 16 分区、峰值 4k msg/s,消费组 8 实例。消费端是 at-least-once:拉取批次 → 逐条写 MySQL 8.0(业务表 + 幂等
背景:at-least-once + 消费端幂等已经是社区共识,前面 170 / 51 / 710 / 681 那几篇把幂等表、业务状态机聊得够透。但还有一个更底层、更少被认真掰扯的分歧:offset 提交这个动作,到底代表什么? 我的理解
«先抛个我想听大家拍砖的问题:你们线上 "auto.offset.reset" 到底设的什么值?设了 "earliest" 就敢拍胸脯说"新消费组一定全量重放"吗? 我们去年就栽在这儿——设了 "earliest" 依然跳过了 6 天历史,
文
标题
摘要