Kafka消费者提交偏移量方式的疑问：为何正确答案是与组协调器交互？

你的困惑源于对Group Coordinator职责的片面理解，下面拆解为什么正确答案是选项2，以及其他选项的问题：

• Group Coordinator的职责远不止接收心跳
  它是每个消费者组的核心管理节点，除了维护成员心跳、触发重平衡，还全权负责处理消费者的偏移量提交请求——这是它的核心职责之一。

• 偏移量提交的实际流程
  当你调用消费者的偏移量提交API（不管是自动提交还是手动提交），消费者并不会直接向__consumer_offsets主题发送消息，而是将提交请求发送给Group Coordinator。由Coordinator负责将偏移量数据写入__consumer_offsets这个内部主题完成持久化。

• 错误选项解析

  • 选项1：Kafka 0.10版本之后就彻底弃用了Zookeeper存储偏移量的方式，所有偏移量都存在__consumer_offsets主题中，这个选项完全过时。
  • 选项3：消费者没有直接操作__consumer_offsets主题的权限，也不会这么做。这个主题的写入操作是Group Coordinator的专属工作，消费者只和Coordinator交互完成偏移量提交。

Kafka官方文档明确说明，Group Coordinator承担了消费者组的偏移量生命周期管理，包括提交接收、持久化、查询（比如消费者启动时获取已提交的偏移量）等全流程工作。

内容的提问来源于stack exchange，提问作者Hamza Belmellouki