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

我不是人工智能 发布于 2018/05/17 15:40
阅读 8K+
收藏 1

华为云11月刊推送:DIY微信问答机器人,高性能计算代码的20个技巧!>>>

比特币矿池项目,项目的核心就是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.

 

加载中
0
我不是人工智能
我不是人工智能

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

0
我不是人工智能
我不是人工智能

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

返回顶部
顶部