二.kafka leader 负载均衡

时间:2021-12-02 21:38:28
每当代理停止或崩溃领导,该代理的分区传输到其他副本。这意味着默认情况下,当代理重新启动时,它将只是所有其分区的跟随者,这意味着它不会用于客户端读取和写入。

为了避免这种不平衡,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