leader_not_available错误需按五步排查:一查分区leader是否为-1或broker不可达;二验zookeeper中/controller和/brokers/ids状态;三析server.log选举日志;四核advertised.listeners网络可达性;五在条件满足时强制删除/controller触发重选举。

当Kafka客户端报出 LEADER_NOT_AVAILABLE 错误时,该分区可能正处于 Leader 重新选举过程中,但也可能是其他环节失效导致元数据中 Leader ID 为 -1 或客户端无法连接已知 Leader。以下是定位与验证该状态的具体操作路径:
一、检查分区当前 Leader 状态
该步骤用于确认分区是否确实处于无 Leader 状态(即 Leader ID = -1),或 Leader 已存在但不可达。这是诊断的起点,直接反映元数据层面是否完成选举。
1、执行命令查看目标 Topic 分区的 Leader 分布:
kafka-topics.sh --bootstrap-server
2、在输出结果中定位对应分区行,观察 Leader 列数值:若显示为 -1,表明当前无有效 Leader;若显示为具体 Broker ID(如 101),需进一步验证该 Broker 是否存活且可连通。
3、对 Leader 列非 -1 的分区,使用 telnet 或 nc 测试该 Broker 的监听端口是否可达:
telnet
二、核查控制器与 ZooKeeper 中的选举状态
ZooKeeper 是 Leader 选举协调的核心依赖,/controller 节点存在性及 /brokers/ids 中的 Broker 注册状态,共同决定选举能否触发或完成。
1、使用 zkCli.sh 连接 ZooKeeper 并检查控制器节点:
ls /controller
2、若返回空列表,说明控制器节点缺失,集群当前无活跃控制器,Leader 选举无法启动;若返回一个数字(如 [101]),记录该 ID 并核对对应 Broker 是否在线。
3、检查所有 Broker 是否正常注册:
ls /brokers/ids
4、比对输出列表与实际运行的 Broker ID 列表,若存在 ID 缺失,表明对应 Broker 未成功加入集群或已异常退出,将导致其上所有分区无法参与选举。
三、分析服务端日志中的选举事件
Kafka Broker 的 server.log 中会明确记录 Controller 触发的 Leader 选举动作及结果,是判断“是否正在选举”最直接的证据。
1、在 Controller 所在 Broker 的日志中搜索关键词:
grep "electing leader" server.log
2、若发现类似 “electing leader for partition [topic,0] from ISR [101,102]” 的日志,且后续无 “successfully elected” 或 “leader is 102” 类确认信息,则表明选举过程卡住或失败。
3、同时搜索 “Failed to elect leader” 或 “ISR is empty” 字样,前者指示选举逻辑异常,后者说明所有同步副本均失联,选举无法进行。
四、验证 advertised.listeners 配置是否导致假性不可用
即使选举已完成、Leader ID 正确写入元数据,若客户端获取到的 Leader 地址(来自 advertised.listeners)不可路由,也会被判定为 LEADER_NOT_AVAILABLE。
1、登录 Leader 所在 Broker,检查 server.properties 中 advertised.listeners 值:
grep "^advertised.listeners=" server.properties
2、确认该值是否为客户端网络可达的 IP 和端口,例如不应为 localhost 或内网地址(如 192.168.x.x)而客户端位于公网。
3、临时修改为客户端可访问地址并重启 Broker,再执行第一步的 describe 操作,观察 Leader 是否仍为 -1 或能否建立连接。
五、强制触发一次 Leader 重选举
当确认控制器存在、Broker 全部在线、ISR 非空,但分区 Leader 仍为 -1 时,可手动干预以推进选举流程。
1、删除 ZooKeeper 中的 /controller 节点(仅限测试或紧急恢复场景):
rmr /controller
2、等待约 5–10 秒,ZooKeeper 将自动重建该节点,并由新当选 Controller 扫描所有分区,对 Leader 为 -1 的分区发起选举。
3、立即执行第一步的 describe 命令,观察 Leader 列是否更新为有效 Broker ID。











