2016-02-02 42 views
1

我有以下設置:
3卡夫卡經紀人和一個3動物園管理員ensamble
1與12個分區和3個副本主題(各卡夫卡經紀人因此的4個分區的領導者)
如何配置停止並重新啓動代理程序後,kafka羣集重新選擇分區引導程序的時間?

我停止的一個經紀人 - 它從集羣中被移除,其分區的領導地位被移動到其餘兩個經紀人

我開始經紀人 - 它重新出現在集羣中,最終領導層得到重新平衡,因此每個經紀人都是4的領導者分區。

它工作正常,除非我發現再平衡時間過長(如分鐘)。這是在沒有負載的情況下發生的 - 沒有消息發送到羣集,也沒有消息被消耗。

卡夫卡版本0.9.0.0,動物園管理員3.4.6

動物園管理員滾動時間= 2000

卡夫卡zookeeper.connection.timeout.ms = 6000

(基本上默認的配置)

有誰知道kafka和/或zookeeper中的配置參數會影響領導者平衡所需的時間嗎?

+0

是auto.leader.rebalance.enable = true set? – Nautilus

+0

是的, - 這是默認情況下是正確的,重新平衡工作正常,只是比我想要更多的時間.. –

回答

2

作爲官方文件http://kafka.apache.org/documentation.html#configuration(可在階類kafka.server.KafkaConfig中找到關於代理配置的更多細節。) 有實際上是一個leader.imbalance.check.interval.seconds屬性默認爲300(5分鐘),將其設置爲在所述30秒做我需要的。

相關問題