apache-kafka - Kafka 什么时候轮换分区领导者？我们有什么属性(property)可以控制它吗？

Question

我想了解 Kafka 多久轮换一个分区领导者？我们有什么属性(property)可以控制它吗？

Answer 1

分区负责人在创建主题时分配。根据 Replica Management 上的 Kafka 文档分区的分配以循环方式进行:

We attempt to balance partitions within a cluster in a round-robin fashion to avoid clustering all partitions for high-volume topics on a small number of nodes. Likewise we try to balance leadership so that each node is the leader for a proportional share of its partitions.

在理想情况下，leader 分区不会轮换。但是，在某些情况下，必须将领导者转移到另一个经纪人，例如代理停止和启动以进行维护或更新。然后领导者将转移到另一个同步副本。

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

选项1:脚本kafka-preferred-replica-election.sh

此命令行工具可用于帮助将领导权恢复到创建主题时存在的副本。请引用online documentation了解更多详细信息以及如何使用它。

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

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 : Controller 触发分区重新平衡检查的频率。 (默认为 300)

• leader.imbalance.per.broker.percentage :每个经纪人允许的领导者不平衡比率。如果每个经纪人超过此值， Controller 将触发领导者余额。该值以百分比形式指定。 (默认为 10)