本地Windows运行Kafka Producer连接EC2实例发送消息失败报错求助

我来帮你排查这个发消息失败的问题——从本地Windows连EC2上的Kafka出现FailedToSendMessageException，大概率是网络连通性或者Kafka监听配置的问题，咱们一步步来解决：

1. 检查EC2安全组的入站规则 #

EC2的安全组默认会阻止外部流量，你需要确保它允许本地机器访问9092端口：

• 登录AWS控制台，找到你的EC2实例，进入对应的安全组配置页面
• 添加一条入站规则：协议选TCP，端口范围填9092，源地址设为你的本地公网IP（可以通过百度搜索“我的IP”获取）
• 测试阶段可以临时用0.0.0.0/0允许所有IP访问（测试完成后记得改回你的IP，避免安全风险）

2. 修改Kafka的advertised.listeners配置 #

你现在配置的是EC2的私有IP，但本地Windows在公网环境下无法直接访问私有IP，需要把这个配置改成EC2的公网IP：

• 登录EC2实例，找到Kafka的server.properties文件（一般在$KAFKA_HOME/config目录下）
• 修改advertised.listeners为：PLAINTEXT://你的EC2公网IP:9092
• 重启Kafka服务让配置生效（先停止Kafka，再停止ZooKeeper，然后启动ZooKeeper，最后启动Kafka）

3. 测试本地到EC2 9092端口的连通性 #

在本地Windows上先验证网络是否能通：

• 用PowerShell执行：Test-NetConnection 你的EC2公网IP -Port 9092，查看TcpTestSucceeded是否为True
• 或者用cmd执行：telnet 你的EC2公网IP 9092，如果能建立连接说明网络没问题；如果不通，还要检查EC2的网络ACL是否允许9092端口的入站流量

4. 确认本地生产者的bootstrap.servers配置 #

你的生产者代码里，bootstrap.servers必须指向EC2的公网IP+9092，而不是私有IP：

props.put("bootstrap.servers", "你的EC2公网IP:9092");

确保这里的地址和Kafka的advertised.listeners完全一致

5. 检查本地Windows防火墙 #

本地防火墙可能拦截了对9092端口的出站请求：

• 临时关闭Windows防火墙测试是否能发送消息
• 如果关闭后正常，就添加入站/出站规则，允许本地机器访问EC2的9092端口

按照这个流程排查下来，基本就能解决本地生产者连EC2 Kafka失败的问题了。

内容的提问来源于stack exchange，提问作者chandra