Kafka消费者再平衡条件

Kafka consumer rebalancing condition

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

中读取数据

创建消费者C2会触发再平衡吗？作为一个更笼统的问题，kafka什么时候会进行rebalance？

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

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