apache-kafka - 如何配置 kafka 集群在停止和重新启动代理后重新选举分区领导所需的时间？

Question

我有以下设置:
3 个 kafka 经纪人和 3 个动物园管理员 ensamble
1 个主题，包含 12 个分区和 3 个副本(因此每个 kafka 代理是 4 个分区的领导者)

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

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

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

卡夫卡版本 0.9.0.0，动物园管理员 3.4.6

动物园管理员tickTime = 2000

卡夫卡动物园管理员.connection.timeout.ms = 6000

(基本上是默认配置)

有谁知道 kafka 和/或 zookeeper 中的哪些配置参数会影响领导者 rabalancing 的时间？

Answer 1

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