1
如果我想通過啓動運行我的消費者代碼的新機器/流程來擴大我的消費者到特定主題,是否讓消費者(在所有機器/進程)使用相同的消費者組ID?卡夫卡會處理所有的協調?跨機器/流程在卡夫卡擴大消費者
(假設有超過消費者的話題在多個分區)
只是想確認一下我的理解。
如果我想通過啓動運行我的消費者代碼的新機器/流程來擴大我的消費者到特定主題,是否讓消費者(在所有機器/進程)使用相同的消費者組ID?卡夫卡會處理所有的協調?跨機器/流程在卡夫卡擴大消費者
(假設有超過消費者的話題在多個分區)
只是想確認一下我的理解。
是的,就這麼簡單!
當消費者加入或離開消費者羣體時,他們會自動在Zookeeper上註冊自己,這反過來會觸發一個在新消費者池中重新分配負載的進程。