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

Question

3

我发现了一道在线测验题:

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

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

是否有人能够解释我的误解并向我指出一些相关文档，因为我在网络上找不到相关内容。

- Hamza Belmellouki

2个回答

0

每个组的协调者都是从内部偏移主题__consumer_offsets的领导者中选择的，该主题用于存储已提交的偏移量。

这在confluent文档此处的第三段中提到。因此，选项2. 它与Group Coordinator代理交互是正确的。

- Raj

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Gerard Klijs · Accepted Answer

源代码是最好的文档。但为了保持一致性，在提交偏移量的时刻，消费者必须仍然拥有该分区的分配。协调器是唯一确知这一点的人。

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