如何平衡卡夫卡领导力？

Question

我的卡夫卡版本是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.(见文件)

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

Answer 2

您可以使用首选副本领导者选举工具:

sh kafka-preferred-replica-election.sh --zookeeper zklist

这可以保证集群中经纪人的领导负荷均衡.