2017-04-14 63 views
1

如果我想通過啓動運行我的消費者代碼的新機器/流程來擴大我的消費者到特定主題,是否讓消費者(在所有機器/進程)使用相同的消費者組ID?卡夫卡會處理所有的協調?跨機器/流程在卡夫卡擴大消費者

(假設有超過消費者的話題在多個分區)

只是想確認一下我的理解。

回答

2

是的,就這麼簡單!

當消費者加入或離開消費者羣體時,他們會自動在Zookeeper上註冊自己,這反過來會觸發一個在新消費者池中重新分配負載的進程。