kafka使用者偏移提交失败:notcoordinatorforgroupexception

b1zrtrql  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(586)

kafka broker版本是kafka 2.11-0.10.2.1我的客户端使用org.apache.kafka的kafka clients(0.10.2.0)包
“自动提交”已启用。在重新启动组协调器代理时,我的消费者抛出了这个错误,我可以看到这些消息的处理过程是重复的。

Offset commit with offsets {topic1-0=OffsetAndMetadata{offset=9, metadata=''}, topic2-1=OffsetAndMetadata{offset=9, metadata=''}, topic3-2=OffsetAndMetadata{offset=11, metadata=''}} failed for group myGroupId: org.apache.kafka.clients.consumer.RetriableCommitFailedException: Offset commit failed with a retriable exception. You should retry committing offsets.
Caused by: org.apache.kafka.common.errors.NotCoordinatorForGroupException: This is not the correct coordinator for this group.

我的问题:
Kafka消费者向哪个节点提交偏移量?给分区负责人还是给小组协调人?
在协调器故障转移期间,使用者是否重新尝试向新的组协调器提交偏移?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题