前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Exception:Connection to node 0 could not be established. Broker may not be available.

Exception:Connection to node 0 could not be established. Broker may not be available.

作者头像
CBeann
发布2023-12-25 17:25:12
2010
发布2023-12-25 17:25:12
举报
文章被收录于专栏:CBeann的博客CBeann的博客

问题:Java调用kafkaAPI写入数据失败,不报错

代码语言:javascript
复制
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.11.0.2
[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : 73be1e1168f91ee2
[main] INFO org.apache.kafka.clients.producer.KafkaProducer - Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - Connection to node 0 could not be established. Broker may not be available.
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - Connection to node 0 could not be established. Broker may not be available.
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - Connection to node 0 could not be established. Broker may not be available.
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - Connection to node 0 could not be established. Broker may not be available.
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - Connection to node 0 could not be established. Broker may not be available.
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - Connection to node 0 could not be established. Broker may not be available.
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - Connection to node 0 could not be established. Broker may not be available.
[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - Connection to node 0 could not be established. Broker may not be available.

解决办法

前提:端口开放 9092 2888 3888

修改kafka的配置文件server.properties,按照自己的IP和主机名称修改下面的配置并且打开

感悟:日志的重要性

开始的时候没加日志配置文件和依赖,只知道运行很久才结束,不报错并且插入不成功,很奇怪

后来加入日志,一下就能看出是连接node失败,百度就解决了

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2022-03-07,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 问题:Java调用kafkaAPI写入数据失败,不报错
  • 解决办法
  • 感悟:日志的重要性
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档