Kafka【问题 03】Connection to node -1 (/IP:9092) could not be established. Broker may not be available.

简介: Kafka【问题 03】Connection to node -1 (/IP:9092) could not be established. Broker may not be available.

1.报错详情

此问题仅出现在云服务器上,非云服务器未出现过一下报错:

15:50:26.736 [kafka-producer-network-thread | producer-1] 
WARN  o.a.k.c.NetworkClient - [processDisconnection,782] - [Producer clientId=producer-1] 
Connection to node -1 (/xxx.xx.xxx.xxx:9092) could not be established. 
Broker may not be available.

2.配置问题

非云服务器:

# 报错时仅配置了
listeners=PLAINTEXT://IP:9092

云服务器:

# 处理后
listeners=PLAINTEXT://云服务器IP:9092
advertised.listeners=PLAINTEXT://云服务器外网IP:9092

3.总结

  • 云服务器有两个IP,监听IP为云服务器IP,而advertised监听IP为云服务器的外网IP。
目录
相关文章
|
18天前
|
消息中间件 Kafka Shell
Connection to node 0 (/172.17.0.8:9092) could not be established. Broker may not be available. 是什么问题?
Connection to node 0 (/172.17.0.8:9092) could not be established. Broker may not be available. 是什么问题?
39 9
|
3月前
|
消息中间件 存储 缓存
Kafka(三)【Broker 存储】(1)
Kafka(三)【Broker 存储】
|
1月前
|
消息中间件 监控 Java
【Kafka节点存活大揭秘】如何让Kafka集群时刻保持“心跳”?探索Broker、Producer和Consumer的生死关头!
【8月更文挑战第24天】在分布式系统如Apache Kafka中,确保节点的健康运行至关重要。Kafka通过Broker、Producer及Consumer间的交互实现这一目标。文章介绍Kafka如何监测节点活性,包括心跳机制、会话超时与故障转移策略。示例Java代码展示了Producer如何通过定期发送心跳维持与Broker的连接。合理配置这些机制能有效保障Kafka集群的稳定与高效运行。
34 2
|
1月前
|
JavaScript
NodeJs——无法使用内网IP访问
NodeJs——无法使用内网IP访问
26 1
|
4月前
|
消息中间件 Cloud Native Kafka
一文搞懂 Kafka consumer 与 broker 交互机制与原理
AutoMQ致力于打造下一代云原生Kafka系统,解决Kafka痛点。本文深入解析Kafka Consumer与Broker的交互机制,涉及消费者角色、核心组件及常用接口。消费者以group形式工作,包括leader和follower。交互流程涵盖FindCoordinator、JoinGroup、SyncGroup、拉取消息和退出过程。文章还探讨了broker的consumer group状态管理和rebalance原理。AutoMQ团队分享Kafka技术,感兴趣的话可以关注他们。
412 3
一文搞懂 Kafka consumer 与 broker 交互机制与原理
|
3月前
|
存储 消息中间件 缓存
Kafka(三)【Broker 存储】(2)
Kafka(三)【Broker 存储】
|
3月前
|
消息中间件 Kafka 网络安全
Kafka. Broker not available
Kafka. Broker not available
128 0
|
4月前
|
消息中间件 负载均衡 监控
【Kafka】Kafka 创建Topic后如何将分区放置到不同的 Broker 中?
【4月更文挑战第13天】【Kafka】Kafka 创建Topic后如何将分区放置到不同的 Broker 中?
|
4月前
|
消息中间件 Kafka 网络安全
Kafka. Broker not available
Kafka. Broker not available
148 0
|
4月前
|
消息中间件 监控 Java
✈️【Kafka技术专题】「核心原理篇」深入实战探索Kafka的Broker的原理及可靠性机制分析
✈️【Kafka技术专题】「核心原理篇」深入实战探索Kafka的Broker的原理及可靠性机制分析
144 0