apache-kafka - Kafka 消费者重新平衡条件

Question

如果我创建一个消费者会怎样C1同组consumerGroup从主题读取数据 A .一段时间后创建消费者 C2 , 在同一个组中，从主题 B 读取数据.

将创建消费者C2触发再平衡？
作为一个更普遍的问题，kafka 什么时候会执行重新平衡？

Answer 1

每次新的消费者加入组或消费者离开组(主动通过调用 close() 或超时)都会触发重新平衡。

此外，如果您订阅了尚未创建的主题，则会在主题创建后触发重新平衡。同样，如果您订阅的主题被删除。此外，如果任何订阅主题的分区数量发生变化。最后但并非最不重要的一点是，如果您通过模式订阅，如果新主题与模式匹配或匹配的主题被删除，或者任何匹配主题的分区数量发生更改，则会发生重新平衡。

见 https://cwiki.apache.org/confluence/display/KAFKA/Kafka+0.9+Consumer+Rewrite+Design