3
我在考慮使用0.9 API版本構建Kafka使用者。請你能解釋消費者重新平衡的含義嗎?這裏提到的消費者和協調員之間有什麼區別?也請你能解釋消費者腦裂問題嗎?Kafka Consumer - Java(0.9 API)
以下是設計草案,它使用經紀人方的高可用消費者協調員來處理消費者重新平衡。通過 將重新平衡邏輯從消費者遷移到協調者,我們 可以解決消費者裂腦問題並幫助消費者客戶端更細。
我在考慮使用0.9 API版本構建Kafka使用者。請你能解釋消費者重新平衡的含義嗎?這裏提到的消費者和協調員之間有什麼區別?也請你能解釋消費者腦裂問題嗎?Kafka Consumer - Java(0.9 API)
以下是設計草案,它使用經紀人方的高可用消費者協調員來處理消費者重新平衡。通過 將重新平衡邏輯從消費者遷移到協調者,我們 可以解決消費者裂腦問題並幫助消費者客戶端更細。
嗨鸚鵡螺,消費者可以在使用kafka api 0.8.2版本時重新平衡,或者它只能在0.9版本中使用 –
是否共同構建了kafka並知道所有的ips消費應用程序 –
對不起,我對老消費者不是很熟悉。你可以在這裏問問email:[email protected] – Nautilus