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