Kafka Topic无Leader且重选失败，求批量重新选举Leader方案

必须要有Leader吗？ #

是的，Kafka的每个分区必须有Leader。所有生产者写入、消费者读取请求都只能通过分区Leader处理，没有Leader的分区会完全不可用，无法进行任何读写操作。

针对你的场景的处理步骤 #

从你提供的Topic信息来看：

CSVForOldSystem PartitionCount: 1 ReplicationFactor: 1 Configs: segment.bytes=1073741824
Topic: CSVForOldSystem Partition: 0 Leader: none Replicas: 1001 Isr: 1001

这个分区的唯一副本和ISR成员是Broker 1001，但Leader为none，说明Broker 1001可能离线或集群无法感知其状态。而你的当前Broker是1006，不在该分区的副本列表中，需要分情况处理：

情况1：Broker 1001可以恢复上线 #

• 启动或修复Broker 1001，确保它能正常连接到Kafka集群。Kafka会自动检测到可用的副本（1001），并将其选举为该分区的Leader，无需手动操作。

情况2：Broker 1001无法恢复 #

需要先将分区副本迁移到可用的Broker（1006），再重新选举Leader：

1. 修改Topic副本配置
   使用Kafka自带的kafka-topics.sh脚本更新副本列表（替换<你的集群地址>为实际的Broker地址，比如localhost:9092）：

   kafka-topics.sh --bootstrap-server <你的集群地址> --alter --topic CSVForOldSystem --replica-assignment 1006
   

   该命令将分区0的副本设置为1006。

2. 手动触发Leader选举
   执行以下命令强制选举1006为该分区的Leader：

   kafka-leader-election.sh --bootstrap-server <你的集群地址> --topic CSVForOldSystem --partition 0 --election-type preferred
   

所有Topic批量重新选举Leader的方法 #

如果需要为集群中所有Topic的所有分区批量重新选举Leader，可以使用以下命令：

kafka-leader-election.sh --bootstrap-server <你的集群地址> --all-topic-partitions --election-type preferred

注意：执行批量选举前，确保所有涉及的Broker都处于正常运行状态，否则可能导致部分分区仍然无法选举出Leader。

内容的提问来源于stack exchange，提问作者Neo000