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消费者向哪个节点提交偏移量?给分区负责人还是给小组协调人?
在协调器故障转移期间,使用者是否重新尝试向新的组协调器提交偏移?
暂无答案!
目前还没有任何答案,快来回答吧!