### Kafka报错:Current offset 6 for partition __consumer_offsets-28 is out of range,如何定位与解决?
此问题通常发生在Kafka消费者尝试从`__consumer_offsets`主题中读取偏移量时,发现指定的偏移量超出范围。可能原因包括:1) 消费者组元数据损坏;2) 主题被清理导致偏移量丢失;3) Kafka版本不兼容。
**定位方法**:检查Kafka日志和`__consumer_offsets`主题的分区数据,确认是否存在偏移量6。使用`kafka-consumer-groups.sh --bootstrap-server --group --describe`命令查看消费者组状态。
**解决办法**:1) 重启消费者以重新提交偏移量;2) 使用`--reset-offsets`重置消费者组偏移量;3) 如果数据完整性受损,重建消费者组或手动修复偏移量;4) 确保Kafka集群和客户端版本一致,并调整`log.retention.hours`避免过早清理。
注意:操作前备份关键数据,避免影响业务运行。
关注
码龄 粉丝数 原力等级 --
- 被采纳
- 被点赞
- 采纳率
Kafka报错:Current offset 6 for partition __consumer_offsets-28 is out of range,如何定位与解决?
收起
- 写回答
- 好问题 0 提建议
- 关注问题
微信扫一扫点击复制链接分享
- 邀请回答
- 编辑 收藏 删除 结题
- 收藏 举报
0条回答 默认 最新
报告相同问题?
提交
- 2020-09-12 12:24九师兄的博客 1.背景 kafka报错 kafka Current offset xxx for partition xxx out range
- 2019-05-21 15:01weixin_30263277的博客 报错背景: CDH集成kafka插件之后,启动kafka时就...2019-05-17 08:18:06,428 ERROR state.change.logger: [Controller id=50 epoch=4447617] Initiated state change for partition __consumer_offsets-8 from Of...
- 2020-04-24 13:15pierre94的博客 部分消费组无法通过broker(new-consumer)正常消费数据,更改消费组名后恢复正常。
- 九师兄的博客 kafka消费报错:Offsets out of range with no configured reset policy for partitions报错原因:当消费者消费offset大于或小于当前kafka集群的offset值时,消费会报错比如场景一:一个consumer group消费某topic,...
- 2021-03-17 16:16idealemail的博客 __consumer_offsets成为位移主题,有以下知识点 1.由kafka自己创建,默认50个分区,每个分区3个副本 2.例如partition-1的leader为broker 4. isr为 4,6,8 ar为4,6,8 3.一个group,计算group的hash值,对50取余得出0-...
- 2019-12-05 17:01性感小毛裤。的博客 通过unclean.leader.election配置解决offset out off range kafka集群突然有一个...ERROR [ReplicaFetcherThread-3-4], Current offset 3381428 for partition [cmsps,4] out of range; reset offset to 3501150...
- 2025-03-13 19:19黑夜开发者的博客 最近用到sentry无法收集与统计数据,结果看到了几个容器始终是restarting的状态,然后看了一下容器内部的日志。
- 2022-11-26 20:01
关于spark 设置redis offset,初始启动时报错,提示Offsets out of range with no configured reset policy for partitions
Programma12的博客 Offsets out of range with no configured reset policy for partitions - 2021-03-14 01:46weixin_39981041的博客 当kafka中的数据丢失时,Spark程序消费kafka中数据的时候就可能会出现以下异常:Lost task 12.0 in stage 398.0 (TID 2311, localhost, executor driver): org.apache.kafka.clients.... Offsets out of range wit...
- 程序猿与汪的博客 Offsets out of range with no configured reset policy for partition 假设我们有10000个数据 sgment就把它分为0-1000,1000-2000,2000-3000… 当我们消费到4500的时候报错了,然后也没有进行处理,过了kafka的生命...
- 没有解决我的问题, 去提问