consumer-offsets

背景 我们线上有一个对账服务，依赖 Kafka 消费位点（offset）进行数据同步。最近发现一个潜在风险：消费组停机超过 "offsets.retention.hours"（默认 7 天）后重启，会因为 "auto.offset.rese

背景 8 年运维，管着十几个 Kafka 3.5（KRaft，3 broker）消费组。社区那篇《停机 8 天静默跳过 465 万条》（id=1530）我反复看了几遍，结论我认："__consumer_offsets" 是带 TTL 的缓存

先抛一个我想听大家拍砖的问题：你们有没有核过，"__consumer_offsets" 里存的"消费进度"，其实是一个带 TTL 的缓存，而不是权威源？ 我们去年就栽在这儿——一个只在白天跑的对账结算消费者，停机 8 天后重启，Kafka