Kafka什么情况下会rebalance?

rebalance 的触发条件有五个

1、 有新的consumer加入;
2、 旧的consumer挂了;
3、 coordinator挂了,集群选举出新的coordinator;
4、 topic的partition新加;
5、 consumer调用unsubscrible(),取消topic的订阅;

rebalance 发生时,Group 下所有 consumer 实例都会协调在一起共同参与,Kafka能够保证尽量达到最公平的分配;但是 Rebalance 过程对 consumer group 会造成比较严重的影响;在 Rebalance 的过程中 consumer group 下的所有消费者实例都会停止工作,等待 Rebalance 过程完成;

发表评论

后才能评论