我发现了一道在线测验题:
消费者如何在Kafka中提交偏移量?
- 直接将偏移量提交给Zookeeper
- 与Group Coordinator broker进行交互
- 直接向__consumer_offsets主题发送消息
我选择了3,但正确答案是2。我不明白为什么,因为我以为Group Coordinator的工作是从一个消费者组的所有消费者接收心跳而不是处理消费者偏移量。
是否有人能够解释我的误解并向我指出一些相关文档,因为我在网络上找不到相关内容。
我发现了一道在线测验题:
消费者如何在Kafka中提交偏移量?
我选择了3,但正确答案是2。我不明白为什么,因为我以为Group Coordinator的工作是从一个消费者组的所有消费者接收心跳而不是处理消费者偏移量。
是否有人能够解释我的误解并向我指出一些相关文档,因为我在网络上找不到相关内容。