【kafka专栏】分区再平衡rebalance事前规避以及处理方法_kafka分区再平衡

一、什么是分区再平衡（Rebalance）

通过前面章节的介绍，我们知道一个主题分区由消费者组内的一个消费者进行消费。

什么是分区再平衡(重平衡)呢？再平衡（重平衡）是相对于第一次平衡状态而言，重新进行分区与消费者的消费关系建立。

• 在启动消费者组所在的服务的时候，就会为消费者分配它可以访问数据的主题分区。这是第一次消费者与分区之间建立关系，是第一次分区平衡。
• 所谓的分区再平衡，就是在数据消费进行时，由于某些外部条件发生变化，发生的消费者与分区之间重新建立关系的动作。

二、什么情况下发生Rebalance？

那什么情况下会发生分区再平衡Rebalance呢？主要是以下四种情况：

1. 消费者组消费主题的分区数量发生变化（增加分区），kafka目前只支持为某个主题增加分区

2. 消费者数量增加，在原有消费者组内消费者应用程序正常运行的情况下，新启动了一个服务，该服务内包含与原有消费者groupId一致的消费者，导致消费者组内消费者增加。

3. 当消费者组以正则表达式的方式订阅主题，当新建了一个主题，并且该主题名称匹配到消费者组的订阅正则表达式。也会触发分区再平衡。

4. 消费某主题的消费者数量的减少。