Kafka - 谁写入 __consumer_offsets 主题？

Question

我对谁写了 __consumer_offset 主题有点困惑。

在 Kafka 权威指南第 4 章第 75 页中，关于这个细节非常通用

消费者如何提交偏移量？它向 Kafka 生成一条消息，发送到一个特殊的 __consumer_offsets 主题，其中包含每个分区的提交偏移量。

在另一个网站中，我一直在阅读有关小组协调员也是抵消经理的文章。我回到汇合文档，找到了这篇文章：

还记得 __consumer_offsets 主题吗？每个消费者组将其所有消费者的状态存储在该主题的单个分区内。组协调代理是该消费者组分区的领导者。这样，每个经纪人都可以成为团体协调员。有了足够多的组，每个经纪人都将充当不同消费者组子集的协调员。

但是我找不到关于谁正在编写有关 __consumer_offset 内部主题的提交偏移量更新的参考资料。是消费者吗？是团体协调员吗？是不是还有什么内在的东西？

Answer 1

小组协调员写入

__consumer_offsets

主题。 从这里

大多数客户端库会自动将偏移量提交到 Kafka 定期进行，负责的 Kafka 经纪人将确保写入 到 __consumer_offsets 主题（因此消费者不会写入 直接那个话题）。