Kafka入门之consumer--rebalance流程

  重平衡(rebalance) 旧版本Kafka依托于Zk进行rebalance，新版本consumer使用了Kafka内置的一个全新的组协调协议。对于每个组而言，Kafka的某个broker会被选举为组协调者(coordinator)。 触发条件： 1.组成员发生变更。 2.组订阅topic数发生变更。比如使用基于正则表达式的订阅，当匹配正则表达式的新topic被创建时则会触发rebalanc

>>阅读原文<<