消费者如何在 Kafka 中提交偏移量？

Question

我发现了一个在线测验问题：

消费者如何在 Kafka 中提交偏移量？

1. 它直接提交Zookeeper中的偏移量
2. 它与 Group Coordinator 代理交互
3. 它直接向__consumer_offsets主题发送消息

   我选择了 3。但正确答案是 2。我不明白为什么，因为我认为 Group Coordinator 的工作是接收来自消费者组的所有消费者的心跳，而不是处理消费者偏移量。

   有人可以消除我的误解并指出一些文档，因为我在网上找不到相关的东西。

Answer 1

源代码将是最好的文档。但是为了保持一致性，重要的是在提交偏移量的那一刻，该消费者仍然分配了该分区。协调员是唯一肯定知道这一点的人。

在提交不再属于客户端的偏移量时，您也可能会注意到这一点。