当生产数据的时候,报错如下:提示没有可用的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}相关推荐

  1. WARN Error while fetching metadata with correlation id 1 : {first=LEADER_NOT_AVAILABLE} (org.apache.

    搭建Kahka集群的时候,创建生产者是遇到的问题,大坑,所以记录下来 报错: 其实就是无法识别leader,那么就是当前主机变得无法识别 解决方法:  配置listeners,后面接本机的ip地址就好 ...

  2. WARN Error while fetching metadata with correlation id 1 : {hotitems=LEADER_NOT_AVAILABLE}

    进入conf/server.properties 把这行注释取消 加上自己的ip地址 亲测有效

  3. 【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.背景 ...

  4. 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 ...

  5. flume报错WARN clients.NetworkClient: Error while fetching metadata with correlation id

    项目场景: 修改linux系统时间,模拟使用flume读取日志文件,并把日志文件信息传输给kafka消费,kafka消费之后,再使用flume读取kafka消费后的日志信息, 问题描述: flume在 ...

  6. 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} ...

  7. 【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 ...

  8. 【kafka】Error while fetching metadata xxx: {TEST=LEADER_NOT_AVAILABLE}

    本人菜鸡一只,该文章会比较短,而且没有比较详细的报错和图片,但是我想解决问题的思路还是可以分享下的! 公司有一个kafka集群,我接手做了些文字匹配的东西之后,好久都没人用过了. 然后最近公司想做统一 ...

  9. kafka生产者报错:[org.apache.kafka.clients.NetworkClient:600] - Error while fetching metadata with corre

    在测试kafka写入数据的时候一直在报错: ... [org.apache.kafka.clients.NetworkClient:600]   - Error while fetching meta ...

最新文章

  1. 树莓派3B创建WiFi热点
  2. 散度、旋度与 Laplacian
  3. 计算密集型分布式内存存储和运算平台架构
  4. window下搭建Python3.7+selenium3.1.1+pycharm环境
  5. k8s安装sqlite3_kubernetes环境部署单节点redis数据库的方法
  6. (数据库系统概论|王珊)第一章绪论-第一节:数据库系统概论
  7. 头条号【编编成程】开通
  8. hessian无法获取连接_PPPoE拨号设置完成后无法上网解决方法【详解】
  9. 使用Lazy对构造进行重构后比较
  10. 测试“测试”的“测试”
  11. 转载:c# serialport类 串口通信 hello world
  12. 【通信原理】第四章 -- 信道
  13. 数据分析03-(数值型描述统计及项目分析)
  14. linux自动备份系统快照,我的 Linux 时光机——Snapper系统级自动备份工具
  15. reportunit 命令_DevExpress之XtraReport 学习
  16. Python常用开发软件有哪些?
  17. Debug和release版本区别 原码反码补码的转换及存储
  18. 一周新论文 | 2020年第12周 | 自然语言处理相关
  19. 洛谷 P1093 [NOIP2007 普及组] 奖学金 AC100分
  20. 利用tldr工具再也不怕记不住Linux命令

热门文章

  1. 阿里云ecs实例怎么增添到IP白名单和安全组?
  2. kmeans聚类图像的像素并可视化
  3. HTML+CSS美食静态网页设计——简单牛排美食餐饮(9个页面)公司网站模板企业网站实现...
  4. 百度地图添加文本标记
  5. 计算机硬盘对计算机速度的影响,固态硬盘会不会影响整个电脑的运行速度
  6. 生产系统功能目标和组织结构
  7. TMS320C6678开发笔记---IBL编译与分析4
  8. JS完成注册页面的省市联动(JS内置对象全局函数,select标签操作)
  9. Java 计算日期差
  10. RabbitMQ 安装使用,Centos系统安装RabbitMQ、Docker安装启动RabbitMQ