我看到提到卡夫卡消费集团协调员和消费集团领导人..。
发布于 2017-02-03 06:08:51
1.有何不同?
消费者组协调器是经纪人之一,而组负责人是消费者组中的消费者之一。
组协调器只不过是一个代理,它接收来自消费者组的所有使用者的心跳(或消息轮询)。每个消费者团体都有一个小组协调员。如果使用者停止发送心跳,协调器将触发再平衡。
2.将集团管理分为两套不同的责任有什么好处?
简短回答
它为您提供了更灵活/可扩展的分配策略,而无需重新启动代理。
长答案
这种分离的关键是组组长负责计算整个组的任务。
这意味着可以在使用者上配置此分配策略(请参阅partition.assignment.strategy使用者配置参数)。
如果分区分配由使用者组协调器处理,则不可能在不重新启动代理的情况下配置自定义分配策略。
有关更多细节,请参见卡夫卡客户端指派方案。
文件引文
来自"卡夫卡权威指南“Narkhede,Shapira & Palino,2017年
当消费者想要加入消费者组时,它会向组协调器发送一个
JoinGroup请求。第一个加入该集团的消费者将成为集团的领头羊。领导者从组协调器接收组中所有消费者的列表(这将包括最近发送心跳的所有使用者,因此被认为是活动的),它负责为每个使用者分配一个分区子集。它使用PartitionAssignor接口的实现来决定哪个分区应该由哪个使用者处理。 ..。在决定分区分配后,使用者领导将分配列表发送给GroupCoordinator,后者将此信息发送给所有使用者。每个消费者只看到自己的任务-领导是唯一的客户流程,有完整的客户名单,在小组和他们的分配。每当再平衡发生时,这个过程都会重复。
https://stackoverflow.com/questions/42015158
复制相似问题