为了避免这种不平衡,Kafka有一个优选副本的概念。如果分区的副本的列表为1,5,9,则节点1优选为节点5或9的引导者,因为它在副本列表中较早。您可以通过运行以下命令让Kafka集群尝试恢复恢复的副本的领导:
> bin / kafka-preferred-replica-election.sh --zookeeper zk_host:port / chroot由于运行此命令可能很繁琐,您还可以配置Kafka通过设置以下配置自动执行此操作:
auto.leader.rebalance.enable = true