SpringBoot与Kafka跨服务器部署无法连接问题

问题根因 #

• 配置格式错误：SpringBoot中spring.kafka.bootstrap-servers配置错误添加了http://前缀。Kafka客户端基于原生TCP协议通信，不需要HTTP协议头，带前缀会导致客户端地址解析逻辑异常。
• 监听器绑定错误：Kafka的KAFKA_LISTENERS配置中，用于跨服务器访问的LISTENER_ALICE监听器绑定地址为kafka0:27017。kafka0是Docker Compose自动分配的内部服务主机名，仅能解析到Docker容器内部的私有IP，监听器不会监听宿主机对外暴露的网卡地址。即使配置了27017:27017的端口映射，外部服务器的流量也无法通过该端口接入Kafka服务。

修复步骤 #

1. 调整Kafka容器的监听器绑定配置，将对外提供服务的监听器绑定到0.0.0.0（即监听所有网卡的流量），修改后的KAFKA_LISTENERS配置如下：

   KAFKA_LISTENERS: LISTENER_BOB://kafka0:29092,LISTENER_FRED://0.0.0.0:9092,LISTENER_ALICE://0.0.0.0:27017
   

   注意：KAFKA_ADVERTISED_LISTENERS配置无需修改，该配置是Kafka返回给客户端的实际连接地址，当前配置的10.255.250.160:27017是SpringBoot服务器可直接访问的地址，符合要求。

2. 修改SpringBoot侧的Kafka连接配置，删除地址前的http://前缀，配置如下：

   spring:
     kafka:
       bootstrap-servers: '10.255.250.160:27017'
   

3. 依次重启Kafka的Docker Compose服务、SpringBoot应用即可。
4. 可选前置校验：重启服务前可以先在SpringBoot所在服务器执行telnet 10.255.250.160 27017验证端口连通性，若能正常连通说明网络层和端口映射配置已经生效。

内容的提问来源于stack exchange，提问作者Lê Công