什么是Kafka的重平衡机制?

它是指当我们的Consumer数量发生变动时,kafka会重新分配topic partition给Consumer,以保证每个

Consumer的分区数量尽可能均衡

简单地说就是实现消费者负载均衡

重平衡的3个触发机制:

1、Consumer数量发送变化

2、订阅的partition发生变化

3、订阅的topic发生变化

当kafka集群要出发重平衡机制时,大致的步骤

  1. 暂停消费
  2. 计算分区分配方案
  3. 通知消费者
  4. 重新飞陪分区
  5. 恢复消费

重平衡会造成 Consumer的 STW,我们应该尽量避免触发它