重新启动代理后,我发现一个主题的领导者中的所有分区都在代理3中,并且我设置了
imbalance.check.interval.seconds300,auto.leader.rebalance.enableTrue,但300秒后没有任何反应。
所以我使用了bin/kafka-preferred-replica-election.sh,并得到了我所期望的结果,领导者被平衡为经纪人 1、2、3。
我想知道为什么自动重新平衡没有发生?kafka-preferred-replica-election.sh和 和有什么区别auto.leader.rebalance.enable?
控制器日志:
[2019-08-14 09:31:33,454] INFO [Controller id=3] 处理自动首选副本领导者选举(kafka.controller.KafkaController)[2019-08-14 09:31:33,454] TRACE [Controller id=3 ] 检查是否需要触发自动领导者平衡(kafka.controller.KafkaController)[2019-08-14 09:31:33,455] DEBUG [Controller id=3] Broker 首选副本 Map(2 -> Map(__consumer_offsets-22 ->矢量(2),__consumer_offsets-4->矢量(2),__consumer_offsets-7->矢量(2),__consumer_offsets-46->矢量(2),__consumer_offsets-25->矢量(2),__consumer_offsets-49->矢量(2),__consumer_offsets-16->矢量(2),__consumer_offsets-28->矢量(2),__consumer_offsets-31->矢量(2),__consumer_offsets-37->矢量(2),__consumer_offsets-19->矢量(2),__consumer_offsets-13 - >矢量(2),fourth_topic-1 - >矢量(2,3,1),__consumer_offsets-43 - >矢量(2),__consumer_offsets-1 - >矢量(2),__consumer_offsets -34 -> 矢量(2), __consumer_offsets-10 -> 矢量(2), __consumer_offsets-40 -> 矢量(2)), 1 -> 地图(__consumer_offsets-30 -> 矢量(1), __consumer_offsets-21 ->矢量(1),__consumer_offsets-27->矢量(1),__consumer_offsets-9->矢量(1),__consumer_offsets-33->矢量(1),__consumer_offsets-36->矢量(1),__consumer_offsets-42->矢量(1),__consumer_offsets-3 - >矢量(1),__consumer_offsets-18 - >矢量(1),__consumer_offsets-15 - >矢量(1),__consumer_offsets-24 - >矢量(1),__consumer_offsets-48 - >矢量(1),__consumer_offsets-6 - >矢量(1),fourth_topic-0 - >矢量(1,2,3),__consumer_offsets-0 - >矢量(1),__consumer_offsets-39 - >矢量(1),__consumer_offsets …
apache-kafka ×1