kafka报错Error while fetching metadata with correlation

kafka报错

server.log输出:
Error when handling request {topics=[indexing]} (kafka.server.KafkaApis)
kafka.admin.AdminOperationException: replication factor: 1 larger than available brokers: 0

运行kafka-console-producer.sh 输出

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

运行kafka-console-consumer.sh 刷屏

{metadata.broker.list=node01.bdp:6667, request.timeout.ms=30000, client.id=console-consumer-73407, security.protocol=PLAINTEXT}

网上的一般解决方案指向kafka由于server.properties的错误配置,导致无法正确连接zookeeper.根源在于kafka与zookeeper无法正常通信,反复重启kafka仍无效.

重启zookeeper后kafka正常.

kafka报错Error while fetching metadata with correlation相关推荐

flume 对接 kafka 报错： Error while fetching metadata with correlation id 35 {=INVALID_TOPIC_EXCEPTION}
flume 对接 kafka 报错:Error while fetching metadata with correlation id 35 : {=INVALID_TOPIC_EXCEPTION} ...
【Kafka】报错：Error while fetching metadata with correlation id 1 : {topic_lcc=LEADER_NOT_AVAILABLE}
文章目录 1.美图 2.背景 3. 解决方法1 3.1 原因 3.2 问题解决 4.场景再现 5.神奇日志 6.解决 6.1 解决方法 7.kafak topic坑 8. 场景再现 1.美图 2.背景 ...
flume报错WARN clients.NetworkClient: Error while fetching metadata with correlation id
项目场景: 修改linux系统时间,模拟使用flume读取日志文件,并把日志文件信息传输给kafka消费,kafka消费之后,再使用flume读取kafka消费后的日志信息, 问题描述: flume在 ...
WARN Error while fetching metadata with correlation id 5 : {testtopic=LEADER_NOT_AVAILABLE}
当生产数据的时候,报错如下:提示没有可用的kafka 主节点 root@ubuntu-130:/opt/kafka_2.11-0.11.0.2/bin# ./kafka-console-produce ...
WARN Error while fetching metadata with correlation id 1 : {first=LEADER_NOT_AVAILABLE} (org.apache.
搭建Kahka集群的时候,创建生产者是遇到的问题,大坑,所以记录下来报错: 其实就是无法识别leader,那么就是当前主机变得无法识别解决方法: 配置listeners,后面接本机的ip地址就好 ...
Kafka : WARN Error while fetching metadata with correlation id xx : {=UNKNOWN_TOPIC_OR_PARTITION}
文章目录 1.美图 2.背景 3.验证 4.场景再现 5. 场景再现 1.美图 2.背景不知道什么原因,用kafka命令发送消息时候,一直报 bin/kafka-console-producer.s ...
使用IntelliJ IDEA导入 Flink 消费kafka报错 Error: A JNI error has occurred, please check your installation an
提示找不到类,pom中已经引用了jar包,使用eclipse也可以执行,就是IntelliJ不行 java.lang.NoClassDefFoundError: org/apache/flink/ap ...
【Spark】Spark 报错 error writing stream metadata exitcode=1073741515
1.场景1 根据博客: https://blog.csdn.net/psp0001060/article/details/83057663 https://blog.csdn.net/lxpqxl/a ...
WARN Error while fetching metadata with correlation id 1 : {hotitems=LEADER_NOT_AVAILABLE}
进入conf/server.properties 把这行注释取消加上自己的ip地址亲测有效
kafka生产者报错：[org.apache.kafka.clients.NetworkClient:600] - Error while fetching metadata with corre
在测试kafka写入数据的时候一直在报错: ... [org.apache.kafka.clients.NetworkClient:600] - Error while fetching meta ...

kafka报错Error while fetching metadata with correlation

kafka报错Error while fetching metadata with correlation相关推荐

最新文章

热门文章