kafka生产者报错:[org.apache.kafka.clients.NetworkClient:600] - Error while fetching metadata with corre
在测试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相关推荐
- HDFS上传文件报错org.apache.hadoop.fs.ChecksumException: Checksum error: file:/hyk/data/hyk.txt
当从本地上传文件到HDFS中时报错 fs.FSInputChecker: Found checksum error: b[0, 69]=6d6f7765696861686168616861686861 ...
- 服务器上Kafka启动报错:error=‘Cannot allocate memory‘ (errno=12)
文章目录 环境 经历如下弯路才查看到报错信息 解决方法 1.kill一些不用的进程,来腾出内存. 2.修改默认配置,减少软件启动需要的内存 启动成功 其他 参考 解决问题思路:大问题拆小问题.从源头( ...
- Kafka 启动报错 AccessDeniedException
Kafka 启动报错 AccessDeniedException 今天在本地电脑window环境上下载kafka,启动zookeeper正常,启动kafka时报:java.nio.file.Acces ...
- kafka启动报错Java HotSpotTM 64-bit Server VM warning:INFO: os::commit_memory
版权声明:版权声明:本文为博主原创文章,未经博主允许不得转载. https://blog.csdn.net/qq_39501726/article/details/81938695 kafka启动报错 ...
- kafka tool报错:Error fetching datea.Offset out of range
kafka tool报错 Error fetching datea.Offset out of range 解决方案: Kafka tool 升级最新2.0版本,没有此错误 转载于:https://w ...
- 【kafka】kafka消费者报错INVALID_FETCH_SESSION_EPOCH
1.概述 kafka消息积压会导致cpu飙升吗 我从kafka中批量拿日志 遍历然后json反序列化成对象 在将对象批量入库 在某次入库之后日志打印INVALID_FETCH_SESSION_EPOC ...
- 【kafka】kafka 启动报错 InvalidReceiveException: Invalid receive (size = -720899)
1.概述 kafka启动报错InvalidReceiveException: Invalid receive (size = -720899) 参考文章:https://bbs.csdn.net/to ...
- 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.背景 ...
最新文章
- 基于EMQ X,打造AIoT物联网视频接入解决方案
- Linux下的虚拟终端(可用于在本机上模拟串口进行调试)
- How to correctly encode .mp4 files for streaming
- 利用第三方浏览器漏洞钓鱼
- 利尔达NB-IOT的PSM和eDRX低功耗模式笔记
- JavaScript笔记2———js的数据类型
- android转usb工具,绿联Type-C转Micro usb数据线,Type-C转安卓接口转换线
- 点点滴滴——变量对象的产生
- vue 引入json地图_前端学习 之 Vue 引入Echarts地图
- 分割线怎么搭建css,css怎么设置分割线
- nn棋盘放n个皇后java_帮忙解决一道大学c++题八皇后问题。在一个8*8的国际象棋盘,有八个皇后,每个皇后占一格:要求棋盘上放上八个皇后是不出现...
- 优化静态html页面速度的步骤好人方法,对网站速度优化的10个简单步骤
- 2017年世界各国GDP总值排名预测榜单
- 大脑神经网络图高清,图神经网络 图像
- 将tif文件转换成mrc文件
- Linux nohup用法
- jQuery下的ajax之省市区三级联动
- Java学习笔记之基础篇
- 科技周刊第五期:科学技术在发展中的作用
- python 量化分析 入门_量化入门-小白到菜鸟的学习路线
热门文章
- python-数据分析基础
- 将Word文档中指定内容锁定
- 演讲者模式投影到幕布也看到备注_演讲者备注怎么显示
- HTML“计算机输出”标签 codekbdsampttvarpre
- Spring Cloud 异常“ Caused by: java.net.UnknownHostException: discovery.host ”
- 处理HttpWebRequest访问https有安全证书的问题
- 5、C++结构体的使用
- 使用基于ggplot2的包ggalluvial绘制桑基图(冲积图)
- 余文乐结婚,杜蕾斯文案炸了!
- 低代码时代的团队分工有哪些?