Kafka 15个无Leader分区的影响及解决方法咨询

指定的Kafka主题正被某应用使用，该主题共18个分区，其中15个处于无Leader状态，针对此情况的疑问及解决方案如下：

疑问解答 #

1. 该主题是否实际仅拥有3个可用分区？即向该主题生产数据的应用只会将数据写入这3个分区？ #

是的，当前仅这3个有Leader的分区可用。Kafka生产者仅能向存在Leader的分区写入数据，无Leader的分区无法处理任何生产请求，应用只会将数据写入这3个正常分区。

2. 该主题是否仍存在18个分区，但发送至15个无Leader分区的消息会处于悬停状态或丢失？ #

18个分区的元数据仍保存在集群的控制器（ZooKeeper或KRaft）中，但发送到无Leader分区的消息无法正常处理：

• 若生产者配置acks=all或acks=1，请求会进入持续重试状态（悬停），直到触发超时；
• 若生产者配置acks=0，消息会直接丢失，因为没有Leader节点确认接收。

解决方案 #

• 排查Broker状态：执行命令kafka-topics.sh --describe --topic <主题名> --bootstrap-server <Broker地址>，查看无Leader分区对应的Broker是否在线、副本同步是否正常。
• 重启异常Broker：若对应Broker宕机或假死，重启该节点，集群控制器会自动尝试重新选举分区Leader。
• 手动触发Leader选举：若Broker正常但Leader未自动选举，使用命令kafka-leader-election.sh --bootstrap-server <Broker地址> --topic <主题名> --partition <分区号> --election-type preferred，批量处理无Leader分区。
• 修复副本同步问题：若分区的同步副本集合（ISR）为空，可临时调低min.insync.replicas配置以恢复Leader，待集群稳定后再调回；或添加新的副本节点，确保分区有可用的同步副本。
• 检查控制器状态：KRaft模式下确认控制器节点正常运行；ZooKeeper模式下检查ZK集群状态，确保元数据同步正常。

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