在测试kafka写入数据的时候一直在报错:

...

[org.apache.kafka.clients.NetworkClient:600]   - Error while fetching metadata with correlation id 589 : {TEST_RECEIVE_TOPIC=UNKNOWN_TOPIC_OR_PARTITION}

[org.apache.kafka.clients.NetworkClient:600]   - Error while fetching metadata with correlation id 590 : {TEST_RECEIVE_TOPIC=UNKNOWN_TOPIC_OR_PARTITION}

[org.apache.kafka.clients.NetworkClient:600]   - Error while fetching metadata with correlation id 591 : {TEST_RECEIVE_TOPIC=UNKNOWN_TOPIC_OR_PARTITION}

...

原因是没有创建kafka的topic,先用命令行执行topic创建命令。后可以正常写入。

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

  1. HDFS上传文件报错org.apache.hadoop.fs.ChecksumException: Checksum error: file:/hyk/data/hyk.txt

    当从本地上传文件到HDFS中时报错 fs.FSInputChecker: Found checksum error: b[0, 69]=6d6f7765696861686168616861686861 ...

  2. 服务器上Kafka启动报错:error=‘Cannot allocate memory‘ (errno=12)

    文章目录 环境 经历如下弯路才查看到报错信息 解决方法 1.kill一些不用的进程,来腾出内存. 2.修改默认配置,减少软件启动需要的内存 启动成功 其他 参考 解决问题思路:大问题拆小问题.从源头( ...

  3. Kafka 启动报错 AccessDeniedException

    Kafka 启动报错 AccessDeniedException 今天在本地电脑window环境上下载kafka,启动zookeeper正常,启动kafka时报:java.nio.file.Acces ...

  4. kafka启动报错Java HotSpotTM 64-bit Server VM warning:INFO: os::commit_memory

    版权声明:版权声明:本文为博主原创文章,未经博主允许不得转载. https://blog.csdn.net/qq_39501726/article/details/81938695 kafka启动报错 ...

  5. kafka tool报错:Error fetching datea.Offset out of range

    kafka tool报错 Error fetching datea.Offset out of range 解决方案: Kafka tool 升级最新2.0版本,没有此错误 转载于:https://w ...

  6. 【kafka】kafka消费者报错INVALID_FETCH_SESSION_EPOCH

    1.概述 kafka消息积压会导致cpu飙升吗 我从kafka中批量拿日志 遍历然后json反序列化成对象 在将对象批量入库 在某次入库之后日志打印INVALID_FETCH_SESSION_EPOC ...

  7. 【kafka】kafka 启动报错 InvalidReceiveException: Invalid receive (size = -720899)

    1.概述 kafka启动报错InvalidReceiveException: Invalid receive (size = -720899) 参考文章:https://bbs.csdn.net/to ...

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

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

最新文章

  1. 基于EMQ X,打造AIoT物联网视频接入解决方案
  2. Linux下的虚拟终端(可用于在本机上模拟串口进行调试)
  3. How to correctly encode .mp4 files for streaming
  4. 利用第三方浏览器漏洞钓鱼
  5. 利尔达NB-IOT的PSM和eDRX低功耗模式笔记
  6. JavaScript笔记2———js的数据类型
  7. android转usb工具,绿联Type-C转Micro usb数据线,Type-C转安卓接口转换线
  8. 点点滴滴——变量对象的产生
  9. vue 引入json地图_前端学习 之 Vue 引入Echarts地图
  10. 分割线怎么搭建css,css怎么设置分割线
  11. nn棋盘放n个皇后java_帮忙解决一道大学c++题八皇后问题。在一个8*8的国际象棋盘,有八个皇后,每个皇后占一格:要求棋盘上放上八个皇后是不出现...
  12. 优化静态html页面速度的步骤好人方法,对网站速度优化的10个简单步骤
  13. 2017年世界各国GDP总值排名预测榜单
  14. 大脑神经网络图高清,图神经网络 图像
  15. 将tif文件转换成mrc文件
  16. Linux nohup用法
  17. jQuery下的ajax之省市区三级联动
  18. Java学习笔记之基础篇
  19. 科技周刊第五期:科学技术在发展中的作用
  20. python 量化分析 入门_量化入门-小白到菜鸟的学习路线

热门文章

  1. python-数据分析基础
  2. 将Word文档中指定内容锁定
  3. 演讲者模式投影到幕布也看到备注_演讲者备注怎么显示
  4. HTML“计算机输出”标签 codekbdsampttvarpre
  5. Spring Cloud 异常“ Caused by: java.net.UnknownHostException: discovery.host ”
  6. 处理HttpWebRequest访问https有安全证书的问题
  7. 5、C++结构体的使用
  8. 使用基于ggplot2的包ggalluvial绘制桑基图(冲积图)
  9. 余文乐结婚,杜蕾斯文案炸了!
  10. 低代码时代的团队分工有哪些?