本书未发布

消费者组重平衡

未匹配的标注

消费者组重平衡

触发条件:

  1. 消费者组成员数量发生变化
  2. 订阅主题发生变化
  3. 订阅主题的分区数发生变化

Broker -> Topic -> Partition -> Consumer, Broker是个集群。
(1)增加或者减少消费者组成员,都会导致原来的消息重平衡。比如启动消费者实例时,就是重平衡的过程。

Kafka消费者的5种状态

Kafka核心

状态流转:

Kafka核心

消费者端重平衡

JoinGroup过程
Kafka核心

SyncGroup过程

Kafka核心

总的来说,就是消费者找协调者询问自己应该消费哪个分区。而协调者让消费者leader制定好方案之后,告知协调者,然后再将方案分发给其他的消费者。

Broker端重平衡

场景分别是新成员加入组、组成员主动离组、组成员崩溃离组、组成员提交位移。

Kafka核心

Kafka核心

Kafka核心

Kafka核心

本文章首发在 LearnKu.com 网站上。

上一篇 下一篇
讨论数量: 0
发起讨论 只看当前版本


暂无话题~