解决Kafka报错LEADER_NOT_AVAILABLE

• 问题描述
• 解决方法

问题描述

消费kafka topic主题的报错 LEADER_NOT_AVAILABLE。

解决方法

连接zookeeper.

${ZOOKEEPER_HOME}/bin/zkCli.sh -server zkhostname:port  

查看 /controller 节点数据。

get /controller

如果结果如上图一样，内容为null的话，删除该znode。然后重启zookeeper服务（本人只重启了zookeeper，未重启Kafka，就不报错了）。

rmr /controller

zookeeper /controller 节点与kafka 分区的主节点选举相关，删除后Kafka会自动重建该节点，并触发主节点选举。

下面是本人新建的学习交流群，欢迎大家进群，请不要发送与行业不相关的信息，尊重彼此的时间精力！