我的项目使用的是kafaka0.10.1.0,我在翻阅源代码试图学习一些东西。
我有一个关于kafka交换组相关元数据的协议的问题,这是一个点对点类型的协议,其中给定消费组的协调器在客户机上运行吗?
org.apache.kafka.clients.consumer.internals.abstractcoordinator的文档提到了协议中的一个步骤:
<li>Group/Leader Selection: The coordinator select the members of the group and chooses one member
as the leader.</li>
所以,似乎组长的逻辑是在客户端运行的。我想这将有利于可伸缩性,从代理中卸载,但我想与kafaMaven确认,我得出了正确的结论。谢谢!
1条答案
按热度按时间mcdcgff01#
根据定义,只有一个协调器,这是一个领导者-追随者协议,而不是p2p,其中每个节点通常是平等的