Kafka自动提交偏移量失败。谁没有大神给看看咋回事?

发布于 2021-12-02 02:29:21 字数 1609 浏览 814 评论 2

比特币矿池项目,项目的核心就是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 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(2

月亮是我掰弯的 2021-12-05 15:17:51

把配置文件中的auto.enable.commit设置为false就不报这个日志了,是不是spring-kafka自己的自动提交策略的问题?

躲猫猫 2021-12-05 03:30:44

对了,配置文件中把auto-commit给关掉后,好像没出来这个问题了(但现在还不确定是不是这个原因);没关的那个还是偶尔会出现。

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文