我的Kafka集群有问题。我有3个代理,因此,例如,当我停止代理1时,具有领导者1的每个主题分区都将使用副本配置中的seconde代理来更改其领导者。因此,这是良好的行为,并且效果很好。
但是,当我重新启动代理1时,我需要执行:
./kafka-preferred-replica-election.sh --zookeeper myHost
因为当前的领导者是另一个副本。
所以我的问题是:有一种方法可以配置Kafka自动执行它?
谢谢
apache-kafka
apache-kafka ×1