我有以下設置:
3卡夫卡經紀人和一個3動物園管理員ensamble
1與12個分區和3個副本主題(各卡夫卡經紀人因此的4個分區的領導者)
如何配置停止並重新啓動代理程序後,kafka羣集重新選擇分區引導程序的時間?
我停止的一個經紀人 - 它從集羣中被移除,其分區的領導地位被移動到其餘兩個經紀人
我開始經紀人 - 它重新出現在集羣中,最終領導層得到重新平衡,因此每個經紀人都是4的領導者分區。
它工作正常,除非我發現再平衡時間過長(如分鐘)。這是在沒有負載的情況下發生的 - 沒有消息發送到羣集,也沒有消息被消耗。
卡夫卡版本0.9.0.0,動物園管理員3.4.6
動物園管理員滾動時間= 2000
卡夫卡zookeeper.connection.timeout.ms = 6000
(基本上默認的配置)
有誰知道kafka和/或zookeeper中的配置參數會影響領導者平衡所需的時間嗎?
是auto.leader.rebalance.enable = true set? – Nautilus
是的, - 這是默認情況下是正確的,重新平衡工作正常,只是比我想要更多的時間.. –