卡夫卡消费者重新平衡条件

如果我使用consumerGroup组创建消费者C1以从主题A读取数据该怎么办？一段时间后，在同一组中创建消费者C2以读取主题B的数据。卡夫卡消费者重新平衡条件

创建消费者C2是否会触发重新平衡？作为一个更普遍的问题，当卡夫卡将执行重新平衡？

2017-02-21 f1sherox

每当新的消费者加入该组或消费者离开组（主动通过呼叫close()或通过超时），将会触发重新平衡。

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

2017-02-21 23:18:55

回答