主要报错信息

WARN Error while fetching metadata with correlation id 0 : {test_topic=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient) 

 

猜测原因

在集群中直接删除运行的Topic,补充:应该是该Topic在使用中(待验证)被直接删除,导致无法预料的后果...

 

解决方案

直接重启集群中的Kafka

 

场景

代码可以从一个topic拉取数据,运算完成后往topic存数据报出上面这个错误,查询Kafka List 只有topic名称,没有数据。

这个错误找了很久没有相关资料,资料过于零碎,也没有比较好的解决方案。只有个警告,无法调试相关代码,也找不到相关源码。现场相关配置也不好更改(不敢直接动集群配置),最后尝试重启的方案来修复这个问题,直接修复成功。


8.16

补充一个情况,如果生产者没建立topic,消费者拉取也会报这个错误。

Logo

CSDN联合极客时间,共同打造面向开发者的精品内容学习社区,助力成长!

更多推荐