Kafka自动提交偏移量失败。谁没有大神给看看咋回事?
比特币矿池项目,项目的核心就是Kafka,个别模块偶尔会出现自动提交偏移量失败的日志,日志如下:
Marking the coordinator 124.160.26.251:9092 (id: 2147483646 rack: null) dead for group bch-jobMakerGroup2
2018-04-17 00:06:08,083 50905560 [rawBlockMessageListener-kafka-consumer-1] WARN [o.a.k.c.c.i.ConsumerCoordinator] - Auto-commit of offsets {bch_rawgbt-0=OffsetAndMetadata{offset=54432, metadata=''}} failed for group bch-jobMakerGroup2: Offset commit failed with a retriable exception. You should retry committing offsets.
2018-04-17 00:06:08,130 50905607 [rawBlockMessageListener-kafka-consumer-1] INFO [o.a.k.c.c.i.AbstractCoordinator] - Discovered coordinator 124.160.26.251:9092 (id: 2147483646 rack: null) for group bch-jobMakerGroup2.
2018-04-17 00:06:09,228 50906705 [blockMakerStratumJobMessageListener-kafka-consumer-1] INFO [o.a.k.c.c.i.AbstractCoordinator] - Marking the coordinator 124.160.26.251:9092 (id: 2147483646 rack: null) dead for group bch-stratumjobGroup2
2018-04-17 00:06:09,228 50906705 [blockMakerStratumJobMessageListener-kafka-consumer-1] WARN [o.a.k.c.c.i.ConsumerCoordinator] - Auto-commit of offsets {bch_stratumjob-0=OffsetAndMetadata{offset=50661, metadata=''}} failed for group bch-stratumjobGroup2: Offset commit failed with a retriable exception. You should retry committing offsets.
2018-04-17 00:06:09,256 50906733 [blockMakerStratumJobMessageListener-kafka-consumer-1] INFO [o.a.k.c.c.i.AbstractCoordinator] - Discovered coordinator 124.160.26.251:9092 (id: 2147483646 rack: null) for group bch-stratumjobGroup2.
用的spring-kafka 1.1.0版本的jar包,kafka核心版本是0.10.2.
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(2)
把配置文件中的auto.enable.commit设置为false就不报这个日志了,是不是spring-kafka自己的自动提交策略的问题?
对了,配置文件中把auto-commit给关掉后,好像没出来这个问题了(但现在还不确定是不是这个原因);没关的那个还是偶尔会出现。