kafka-configs.sh --bootstrap-server localhost:9092 \ --describe --entity-type topics --entity-name order-event # consumer.properties auto.offset.reset=earliest retention.ms=604800000
消费一启动就报 OffsetOutOfRangeException: Offsets out of range with no configured error handling strategy。先别急着动参数,把报错原文和时间点记下来,顺序反了容易白折腾。
原因不复杂,记录下来的位点指向的消息已经被 retention.ms 或 retention.bytes 清掉,auto.offset.reset 又没显式配置,组里找不到能用的起点。
这次卡住的地方就在「Kafka offset 越界」这一环,单独把它拎出来验证,别和其他改动混在同一次发布里。备份不是备了就行,恢复一次才算数,很多备份文件打开才发现是空的。
接口问题先分清是没发出去、发出去了没收到,还是收到了处理失败。偶发问题先统计频率,一小时几次和一天一次,查法完全不同。
改完顺手把文档补一句,省得下次自己重新推一遍。监控和日志的时间要对上,时区不一致会多绕很大一圈。
处理上按这个顺序:确认 retention 配置和磁盘告警的时间点能不能对上;显式把 auto.offset.reset 设成 earliest;已经丢数据的场景单独跑一次对账 把差额手工补上。
改完只确认一件事:消费组从有效位点恢复,日志里不再刷 OffsetOutOfRange。
