现象描述:

代码连接本地kafka没有问题 能监听到监听的topic,可获取通道中的所有topic

将kafka放到服务器上,本地程序启动报异常,可获取kafka中所有的topic,但是监听topic不起作用

启动时,报下面两个异常

Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected

Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.

解决方案:

kafka:
TOPIC: 002
#kafka历史队列
TOPICH: 102
producer:
bootstrap-servers: IP:端口
key-serializer: org.apache.kafka.common.serialization.IntegerSerializer
value-serializer: org.apache.kafka.common.serialization.StringSerializer
retries: 10
acks: all
linger.ms: 1
batch.size: 16384
buffer.memory: 33554432
consumer:
group-id: consumer-group
auto-commit-interval: 1S
auto-offset-reset: earliest
enable-auto-commit: true
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

在kafka 下面添加

kafka:
bootstrap-servers: IP:端口,IP:端口,IP:端口

问题解决

Bootstrap broker localhost9092 (id -1 rack null) disconnected相关推荐

  1. 【问题解决】Kafka报错 Bootstrap broker x.x.x.x:9092 (id: -1 rack: null) disconnected

    问题复现 近日针对某一客户需求开发了一个需要使用Kafka的功能,功能是什么暂且不论,在本地虚机的Kafka连接一切正常遂放到测试服务器上验证功能,以下是监听topic成功和警告报错: 2023-05 ...

  2. 命令消费kafka报错(id: -1 rack: null) disconnected

    CDP 717环境使用kafka-console-consumer 命令消费kafka报错如下 23/03/28 09:19:07 WARN clients.NetworkClient: [Consu ...

  3. 【kafka】kerberos认证下 kafka 报错Bootstrap broker host:ip (id: -1 rack: null) disconnected

    文章目录 1.概述 1.概述 本博文中的IP都是随便写的. 公司整了一个新的环境,然后我要进行适配,结果发现对方有认证,无法直接使用,使用控制台生产和消费的时候报错. [domain_realm][r ...

  4. kafka报错:Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected

    这是一个惨痛的教训 就在昨天我和我四个同事因为这个问题搞到了夜里十一点半,啊啊啊啊啊!!!太恶心了!!! 在启动工程时,kafka报这个错误,在配置文件中配置kafka的依赖,和另一个服务器上配置的一 ...

  5. kafka发送数据报错: Error connecting to node xxxxx:9092 (id: 1 rack: null)java.net.UnknownHostExceptio

    报错内容: warn报错: [kafka-producer-network-thread | producer-1] WARN  org.apache.kafka.clients.NetworkCli ...

  6. Kafka Group coordinator xxx:9092 (id: xxx rack: null) is unavailable or invalid

    问题描述: Kafka本身启动和相互通信没有问题,但是在使用Java API 模拟消费者连接到Kafka的时候出现报错 2022-03-03 09:31:22[Consumer clientId=co ...

  7. Group coordinator 192.169.0.16:9092 (id: 2147483647 rack: null) is unavailable or invalid due to cau

    kafka报错 [Consumer clientId=consumer-qizidou-1, groupId=qizidou] Group coordinator 192.169.0.16:9092 ...

  8. 【Kafka】kafka 卡死 Discovered coordinator xx:9092 (id: xxx rack: null) for group xxx

    文章目录 1.背景 1.背景 构建了一个kafka消费组,然后主要是想获取kafka的partition的开始offset 和结束的offset,但是获取的时候这里再某些环境下这里卡死了. 程序如下 ...

  9. 【Kafka】docker下kafka报错 IOException: Connection to xxx:19093 (id: 1002 rack: null) failed

    1.背景 因为某些原因,kafka在Docker内部的Ip为9092,docker外部映射的ip为9093,但是现在网络不通了,查看了一下发现,kafka server.log下日志错误如下 [202 ...

  10. Spark消费kafka任务卡死:Marking the coordinator xxx:9092 (id: 2147483647 rack: null) dead for group xxx

    1.背景 2. 问题出现 运行了一个spark任务,然后,发现有一个Job特别的慢,其他的最多用了30分钟,但是这个任务却运行了 1.1个小时,数据量是100万的数据. 2.1 任务 点击进入 2.2 ...

最新文章

  1. it is likely that the remote side declared peer gone on this jvm
  2. docker化你的java应用(下)
  3. 【pmcaff】纪录片:互联网时代(互联网人必读大片)
  4. JavaScript学习代码整理(二)--函数
  5. Java 调用接口工具类并设置请求和传输超时时间
  6. Interleaving String
  7. 华思视频 CCNA 听而思
  8. 小程序跨行跨列多列复杂表格实现
  9. Linux 命令(53)—— exit 命令(builtin)
  10. Adobe Photoshop源代码以及3800万用户信息泄漏
  11. CENTOS6.6上搭建单实例ORACLE12C
  12. setiosflags与setw使用说明
  13. 计算机自检报错无法开机,电脑开机不自检无显示是怎么回事?
  14. MCU、MPU、DSP、FPGA是什么意思
  15. China Unicom笔面试
  16. 微信公众号开发模式开启总结
  17. 动态规划-背包问题(1)
  18. nuxt启动报错: Error: getaddrinfo ENOTFOUND 0
  19. ubuntu系统制作usb启动盘
  20. 论文分享 Simple Baselines for Human Pose Estimation and Tracking

热门文章

  1. 2022-2027年中国家用清洁产品行业发展监测及投资战略研究报告
  2. C语言short转成int,short转换int的小例子
  3. 打造有身体的 AI丨记青源Workshop具身智能与机器人研讨会(2022年第8期)
  4. 12306自动抢票软件
  5. Codeforces D. Berserk And Fireball(贪心)
  6. 阿里网盘阿里云盘----手机端PC端
  7. 如歌岁月--之《老鹰之歌》
  8. 链接测试工具-Xenu
  9. matlab读取数据流,【OpenBCI】(1):Matlab实时读取数据流(labstreaminglayer)
  10. 实现从oss(阿里云)服务器批量下载文件