2016-02-23 55 views
3

我在考慮使用0.9 API版本構建Kafka使用者。請你能解釋消費者重新平衡的含義嗎?這裏提到的消費者和協調員之間有什麼區別?也請你能解釋消費者腦裂問題嗎?Kafka Consumer - Java(0.9 API)

以下是設計草案,它使用經紀人方的高可用消費者協調員來處理消費者重新平衡。通過 將重新平衡邏輯從消費者遷移到協調者,我們 可以解決消費者裂腦問題並幫助消費者客戶端更細。

回答

2

消費者重新平衡意味着消費羣體正在重新平衡消費羣體消費者之間的分區,這種情況發生在新消費者進入或離開該羣體時。

每個消費者羣體都有一個協調員,基本協調該羣組。

如果您想了解更多關於新消費者的信息,您可以閱讀this

分裂腦是分佈式系統的一個常見問題,當網絡分區發生時,系統的不同部分不能相互通信,也不會意識到這一點。你可以查看它here

+0

嗨鸚鵡螺,消費者可以在使用kafka api 0.8.2版本時重新平衡,或者它只能在0.9版本中使用 –

+0

是否共同構建了kafka並知道所有的ips消費應用程序 –

+0

對不起,我對老消費者不是很熟悉。你可以在這裏問問email:[email protected] – Nautilus

相關問題