如何配置kafka集群在停止和重启broker后重新选举分区领导的时间？

Question

我有以下设置：

3个卡夫卡经纪人和3个动物园管理员

1个主题，12个分区和3个副本(因此每个kafka broker是4个分区的领导者)

我停止了其中一个代理-它从集群中删除，其分区的领导权转移到剩下的两个代理

我重新启动了代理-它重新出现在集群中，最终领导权重新平衡，因此每个代理都是4个分区的领导者。

它工作得很好，除了我发现重新平衡之前花费的时间太长(比如几分钟)。这在没有负载的情况下发生-没有消息被发送到集群，没有消息被消耗。

Kafka版本0.9.0.0，zookeeper 3.4.6

zookeeper tickTime = 2000

kafka zookeeper.connection.timeout.ms = 6000

(基本上是默认配置)

有没有人知道kafka和/或zookeeper中的哪些配置参数会影响leader重新平衡所需的时间？

Answer 1

正如官方文档http://kafka.apache.org/documentation.html#configuration (有关代理配置的更多详细信息，可以在scala类kafka.server.KafkaConfig中找到)中所述。实际上有一个leader.imbalance.check.interval.seconds属性，它的默认值是300 (5分钟)，将它设置为30秒就可以满足我的需要。