卡夫卡消費者重新平衡條件

如果我使用consumerGroup組創建消費者C1以從主題A讀取數據該怎麼辦？一段時間後，在同一組中創建消費者C2以讀取主題B的數據。卡夫卡消費者重新平衡條件

創建消費者C2是否會觸發重新平衡？作爲一個更普遍的問題，當卡夫卡將執行重新平衡？

2017-02-21 f1sherox

每當新的消費者加入該組或消費者離開組（主動通過呼叫close()或通過超時），將會觸發重新平衡。

此外，如果您訂閱尚未創建的主題，則會在創建主題後觸發重新平衡。同樣，如果您訂閱的主題被刪除。此外，如果任何訂閱主題的分區數量發生更改。最後但並非最不重要的一點是，如果您通過模式進行訂閱，如果新主題與模式匹配，或者匹配主題被刪除或分區數量因任何匹配主題而發生更改，則會發生重新平衡。

2017-02-21 23:18:55

回答