卡夫卡什么时候轮换分区领袖？我们有什么财产来控制它吗？

Question

我想了解卡夫卡多久轮换一次分区领袖？我们有什么财产来控制它吗？

Answer 1

分区领导者在创建主题时被分配给。根据副本管理上的卡夫卡文档，分区的分配是以循环方式进行的：

我们试图以循环的方式平衡集群中的分区，以避免在少量节点上为大容量主题集群所有分区。同样，我们试图平衡领导能力，以便每个节点都是其分区的比例共享的领导者。

在理想世界中，领导分区不会旋转。但是，在某些情况下，领导者必须转移到另一个代理，例如代理停止并启动以进行维护或更新。然后，领导将被转移到另一个不同步的副本。

要管理领导分区中的这些转移(例如，处理不平衡)，您有两个选项。

选项1:脚本kafka-首选-复制-election.sh

此命令行工具可用于帮助在创建主题时恢复对副本的领导。有关更多细节和如何使用它，请参考在线文件。

下面是最简单的例子。这将触发所有主题的重新分配。

kafka-preferred-replica-election.sh --zookeeper localhost:2181

选项2:使用代理配置实现自动再平衡

在代理级别，您有以下配置，帮助您指导主题领袖的自动再平衡：

• auto.leader.rebalance.enable：支持汽车领导者平衡。后台线程定期检查分区先导的分布，通过leader.imbalance.check.interval.seconds进行配置。如果领导不平衡超过leader.imbalance.per.broker.percentage，将触发领导重新平衡到分区的首选领导。(默认为true)
• leader.imbalance.check.interval.seconds：由控制器触发分区再平衡检查的频率。(默认值为300)
• leader.imbalance.per.broker.percentage：每个经纪人允许的领导不平衡比率。如果控制器高于每个代理的这个值，则会触发领导者平衡。该值以百分比为单位。(默认值为10)