本书未发布
消费者组重平衡
消费者组重平衡
触发条件:
- 消费者组成员数量发生变化
- 订阅主题发生变化
- 订阅主题的分区数发生变化
Broker -> Topic -> Partition -> Consumer, Broker是个集群。
(1)增加或者减少消费者组成员,都会导致原来的消息重平衡。比如启动消费者实例时,就是重平衡的过程。
Kafka消费者的5种状态
状态流转:
消费者端重平衡
JoinGroup过程
SyncGroup过程
总的来说,就是消费者找协调者询问自己应该消费哪个分区。而协调者让消费者leader制定好方案之后,告知协调者,然后再将方案分发给其他的消费者。
Broker端重平衡
场景分别是新成员加入组、组成员主动离组、组成员崩溃离组、组成员提交位移。