kafka报错LEADER_NOT_AVAILABLE

「爱情、让人受尽委屈。」 2022-05-28 04:06 377阅读 0赞

三点集群，之前运行ok，重启后报错：

Error while fetching metadata with correlation id 10 : \{yqjp-devices-sendPackage=LEADER\_NOT\_AVAILABLE\}

伴随报错：

Caused by: java.lang.ArithmeticException: / by zero

(这个报错貌似是程序架构里面关于kafka的lib报出，

相关代码：return DefaultPartitioner.toPositive(Utils.murmur2(keyBytes)) % numPartitions;

但对应topic的partition应该为1，按理不该报错，没搞明白)

但利用脚本测试又是OK的，说明zookeeper和kafka配置应该没有问题，测试脚本参考(单节点测试，多节点同理)：

kafka-topics.sh --create --zookeeper 192.168.1.22:2181 --replication-factor 2 --partitions 1 --topic HelloWorld

kafka-console-producer.sh --broker-list  192.168.1.22 :9092 --topic  HelloWorld

kafka-console-consumer.sh --zookeeper 192.168.1.22:2181 --from-beginning --topic HelloWorld

怀疑topic出了问题，删除报错的topic，先用如下脚本删除：

**./kafka-topics.sh --delete --zookeeper 【zookeeper server】  --topic 【topic name】**

但仍然报错，感觉没删除干净，只是标记为删除状态。

后来采用kafka可视化管理工具ZK\_UI把里面的东西全部删除(测试环境)，并重启了zookeeper和kafka，恢复正常，之前报错的topic也不报错了，ZK\_UI安装参考：

https://www.ilanni.com/?p=12467

http://www.cnblogs.com/smail-bao/p/7794636.html

![70][]

全程搭建无报错，感谢分享。

[70]: /images/20220528/b560afb3114244549552d8e383918c6c.png

发表评论取消回复

表情：

评论列表（有 0 条评论，377人围观）

还没有评论，来说两句吧...

相关阅读

相关 Kafka各种报错

Kafka各种报错 * 1.Replication factor: 2 larger than available brokers: 1 * 2.ERROR ...

淡淡的烟草味﹌/ 2024年04月18日 10:33/ 0 赞/ 68 阅读

相关 kafka报错解决 kafka.errors.NoBrokersAvailable: NoBrokersAvailable

报错为：kafka.errors.NoBrokersAvailable: NoBrokersAvailable 这个问题我之前也遇到过，但是这次我突然就想通了，之前我以为是没

朴灿烈づ我的快乐病毒、/ 2022年12月23日 06:57/ 0 赞/ 171 阅读

相关 kafka启动报错--broker id

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEx

你的名字/ 2022年11月07日 05:29/ 0 赞/ 147 阅读

相关 kafka-eagle 8048页面报错：500

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTEx

古城微笑少年丶/ 2022年11月06日 15:52/ 0 赞/ 194 阅读

相关 kafka报错LEADER_NOT_AVAILABLE

三点集群，之前运行ok，重启后报错： Error while fetching metadata with correlation id 10 : \{yqjp-device

「爱情、让人受尽委屈。」/ 2022年05月28日 04:06/ 0 赞/ 378 阅读

相关 kafka进程不存在查看日志报错

kafka进程不存在查看日志报如下错误信息 ![70][] 原因：日志保留时间设置的太小，日志被清解决：修改kafka配置文件server.properties中log

谁借莪１个温暖的怀抱￠/ 2022年05月19日 07:26/ 0 赞/ 289 阅读

相关 spark streaming 读kafka写入hbase报错

使用spark streaming消费kafka topic系消息，再写入到hbase中，使用spark submit 他job时，报了一些错误，此处归纳一下： 1,

àì夳堔傛蜴生んèń/ 2022年04月12日 03:51/ 0 赞/ 529 阅读

相关 kafka报错org.apache.kafka.clients.consumer.CommitFailedException

报错如下： org.apache.kafka.clients.consumer.CommitFailedException: Commit cannot be com

男娘i/ 2022年01月29日 00:55/ 0 赞/ 729 阅读

相关 ELFK结合Kafka报错：InstanceAlreadyExistsException

InstanceAlreadyExistsException错误在ELFK集群结合Kafka集群的配置过程中，通过filebet收集日志传输到kafka，然后Kafka

向右看齐/ 2021年12月23日 23:19/ 0 赞/ 582 阅读

相关启动kafka报错

执行启动kafka服务的命令时报错：nohup bin/kafka-server-start.sh config/server.properties 2>&1 & \[201

川长思鸟来/ 2021年11月17日 05:08/ 0 赞/ 498 阅读