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-producer.sh --broker-list 192.168.13.130:9092 --topic testtopic
>hello
[2019-07-14 23:42:47,318] WARN Error while fetching metadata with correlation id 1 : {testtopic=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2019-07-14 23:42:47,512] WARN Error while fetching metadata with correlation id 3 : {testtopic=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2019-07-14 23:42:47,631] WARN Error while fetching metadata with correlation id 4 : {testtopic=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2019-07-14 23:42:47,790] WARN Error while fetching metadata with correlation id 5 : {testtopic=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2019-07-14 23:42:48,228] WARN Error while fetching metadata with correlation id 6 : {testtopic=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2019-07-14 23:42:48,365] WARN Error while fetching metadata with correlation id 7 : {testtopic=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2019-07-14 23:42:48,496] WARN Error while fetching metadata with correlation id 8 : {testtopic=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2019-07-14 23:42:48,635] WARN Error while fetching metadata with correlation id 9 : {testtopic=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2019-07-14 23:42:48,777] WARN Error while fetching metadata with correlation id 10 : {testtopic=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
[2019-07-14 23:42:48,916] WARN Error while fetching metadata with correlation id 11 : {testtopic=LEADER_NOT
临时解决思路:
重新创建kafka节点id,重启kafka
修改server.properties文件,修改节点
root@ubuntu-130:/opt/zookeeper/zookeeper-3.4.8/bin# cd /opt/kafka_2.11-0.11.0.2/config/
root@ubuntu-130:/opt/kafka_2.11-0.11.0.2/config# vim server.properties
root@ubuntu-130:/opt/kafka_2.11-0.11.0.2/config## The id of the broker. This must be set to a unique integer for each broker.
broker.id=1000
并删除logs下的所有文件解决
重启后解决
./kafka-server-start.sh ../config/server.properties
WARN Error while fetching metadata with correlation id 5 : {testtopic=LEADER_NOT_AVAILABLE}相关推荐
- WARN Error while fetching metadata with correlation id 1 : {first=LEADER_NOT_AVAILABLE} (org.apache.
搭建Kahka集群的时候,创建生产者是遇到的问题,大坑,所以记录下来 报错: 其实就是无法识别leader,那么就是当前主机变得无法识别 解决方法: 配置listeners,后面接本机的ip地址就好 ...
- WARN Error while fetching metadata with correlation id 1 : {hotitems=LEADER_NOT_AVAILABLE}
进入conf/server.properties 把这行注释取消 加上自己的ip地址 亲测有效
- 【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.背景 ...
- 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 ...
- flume报错WARN clients.NetworkClient: Error while fetching metadata with correlation id
项目场景: 修改linux系统时间,模拟使用flume读取日志文件,并把日志文件信息传输给kafka消费,kafka消费之后,再使用flume读取kafka消费后的日志信息, 问题描述: flume在 ...
- 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} ...
- 【Error】 WARN [Producer clientId=console-producer] Error while fetching metadata wit
今天在使用Kafka生产数据时出现一个错误,具体报错如下 2021-12-29 18:17:50,662] WARN [Producer clientId=console-producer] Erro ...
- 【kafka】Error while fetching metadata xxx: {TEST=LEADER_NOT_AVAILABLE}
本人菜鸡一只,该文章会比较短,而且没有比较详细的报错和图片,但是我想解决问题的思路还是可以分享下的! 公司有一个kafka集群,我接手做了些文字匹配的东西之后,好久都没人用过了. 然后最近公司想做统一 ...
- kafka生产者报错:[org.apache.kafka.clients.NetworkClient:600] - Error while fetching metadata with corre
在测试kafka写入数据的时候一直在报错: ... [org.apache.kafka.clients.NetworkClient:600] - Error while fetching meta ...
最新文章
- 树莓派3B创建WiFi热点
- 散度、旋度与 Laplacian
- 计算密集型分布式内存存储和运算平台架构
- window下搭建Python3.7+selenium3.1.1+pycharm环境
- k8s安装sqlite3_kubernetes环境部署单节点redis数据库的方法
- (数据库系统概论|王珊)第一章绪论-第一节:数据库系统概论
- 头条号【编编成程】开通
- hessian无法获取连接_PPPoE拨号设置完成后无法上网解决方法【详解】
- 使用Lazy对构造进行重构后比较
- 测试“测试”的“测试”
- 转载:c# serialport类 串口通信 hello world
- 【通信原理】第四章 -- 信道
- 数据分析03-(数值型描述统计及项目分析)
- linux自动备份系统快照,我的 Linux 时光机——Snapper系统级自动备份工具
- reportunit 命令_DevExpress之XtraReport 学习
- Python常用开发软件有哪些?
- Debug和release版本区别 原码反码补码的转换及存储
- 一周新论文 | 2020年第12周 | 自然语言处理相关
- 洛谷 P1093 [NOIP2007 普及组] 奖学金 AC100分
- 利用tldr工具再也不怕记不住Linux命令
热门文章
- 阿里云ecs实例怎么增添到IP白名单和安全组?
- kmeans聚类图像的像素并可视化
- HTML+CSS美食静态网页设计——简单牛排美食餐饮(9个页面)公司网站模板企业网站实现...
- 百度地图添加文本标记
- 计算机硬盘对计算机速度的影响,固态硬盘会不会影响整个电脑的运行速度
- 生产系统功能目标和组织结构
- TMS320C6678开发笔记---IBL编译与分析4
- JS完成注册页面的省市联动(JS内置对象全局函数,select标签操作)
- Java 计算日期差
- RabbitMQ 安装使用,Centos系统安装RabbitMQ、Docker安装启动RabbitMQ