无法从本地主机连接至其他机器上的Kafka服务器求助

这个问题我碰到过好多次，核心原因出在advertised.listeners的配置上，咱们一步步来排查解决：

1. 修正advertised.listeners配置 #

你当前配置里的advertised.listeners=SASL_PLAINTEXT://localhost:9093是关键问题！当远程客户端连接Kafka Broker时，Broker会把这个advertised.listeners的地址返回给客户端，客户端后续就会尝试连接这个地址。如果设成localhost，远程客户端会去连自己机器的localhost，自然无法访问到你的Kafka服务器。

你需要把注释掉的那行配置打开，替换成服务器的实际可访问IP：

advertised.listeners=SASL_PLAINTEXT://10.97.123.52:9093

确保这个IP是你的本地机器能够ping通、并且能访问到的服务器IP。

2. 调整listeners配置（可选但推荐） #

当前的listeners=SASL_PLAINTEXT://localhost:9093意味着Kafka只监听本机的9093端口，远程请求可能无法到达。建议改成监听所有网卡：

listeners=SASL_PLAINTEXT://0.0.0.0:9093

这样Kafka会接受来自任何网卡的连接请求。

3. 检查端口与防火墙 #

确保Kafka服务器的9093端口已经开放：

• 检查服务器防火墙/安全组规则，允许你的本地机器IP访问9093端口；
• 可以在本地用telnet 10.97.123.52 9093或者nc -zv 10.97.123.52 9093测试端口是否可达。

4. 重启Kafka服务 #

修改完配置后，一定要重启Kafka服务，让新的配置生效。

5. 客户端连接配置 #

客户端代码里指定的broker地址要和advertised.listeners完全一致，同时别忘了配置SASL认证相关参数（因为你用的是SASL_PLAINTEXT协议），示例如下：

// Java客户端配置示例
Properties props = new Properties();
props.put("bootstrap.servers", "10.97.123.52:9093");
props.put("security.protocol", "SASL_PLAINTEXT");
props.put("sasl.mechanism", "PLAIN");
props.put("sasl.jaas.config", "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"你的用户名\" password=\"你的密码\";");

额外注意 #

如果之前已经尝试过连接，客户端可能缓存了旧的地址，建议重启客户端进程再试。

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