apache-kafka - 如何负载均衡 Kafka 领导层？

Question

我的kafka版本是kafka_2.9.2-0.8.1.1 .我在集群中有两个代理，4 个主题，每个主题有 4 个分区。

当我跑
sh kafka-topics.sh --describe --zookeeper rhost:2181
对于所有主题/分区，我将代理 1 视为领导者。

如何负载平衡领导者？

例如，对于主题 1 和主题 2，代理 1 作为领导者和
对于主题 3 和主题 4，代理 2 作为领导者。

Answer 1

分区应该自动重新平衡，因为代理配置参数的默认值 auto.leader.rebalance.enable是 true . (见 documentation)

但是，默认情况下，此重新平衡每 5 分钟发生一次，如 leader.imbalance.check.interval.seconds 所定义的那样。范围。如果您希望这种情况更频繁地发生，则必须修改此参数。