kafka专题

Kafka专题:3.kafka协调者

2019-02-07  本文已影响0人  北交吴志炜

主消费者负责计算分区的分配,将结果发送给协调者。所有消费者从协调者处获取自己的分区信息。
每个消费者需要发送两种请求给协调者
1.加入组请求。协调者收集消费组的所有消费者,并选举出一个主消费者执行分区分配工作。
2.同步组请求。主消费者完成分区分配,由协调者将分区的分配结果传播给每个消费者。

消费组的状态主要有下面3个
1.准备再平衡:有消费者离开或者加入消费组,需要执行一次rebalance
2.等待同步:协调者等待主消费者的分区分配结果
3.稳定:协调者返回分区分配结果给消费者

协调者除了管理消费者的负载均衡,将分区的分配发送给消费者。还会接收消费者的心跳,以此监控,消费者成员是否还存活。

上一篇下一篇

猜你喜欢

热点阅读