Spring Boot应用无法连接Docker部署的Kafka Broker问题排查

连接失败由两个配置错误直接导致：

• 端口映射规则写错
  你当前Kafka服务的端口配置为- "9092"，该写法仅会将容器内9092端口映射到宿主机的随机临时端口，不会绑定到宿主机固定的9092端口，本地客户端访问localhost:9092时根本没有对应服务监听。
• 监听器配置和容器网络不兼容
  你使用的KAFKA_ADVERTISED_HOST_NAME、KAFKA_ADVERTISED_PORT是Kafka早期版本的遗留配置，在Docker容器网络隔离场景下会出现客户端拿到的Broker访问地址和实际路由地址不匹配的问题，你之前手动调整监听器参数启动失败，基本都是没有区分监听地址和广播地址的绑定规则导致的。

1. 将docker-compose.yml中Kafka服务部分的配置替换为如下内容：

version: '3.8'
services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"
    restart: unless-stopped
  kafka:
    image: wurstmeister/kafka
    ports:
      - "9092:9092"
    environment:
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://127.0.0.1:9092
      KAFKA_CREATE_TOPICS: "toAll:1:1"
      KAFKA_AUTO_CREATE_TOPICS_ENABLE: 'false'
    restart: unless-stopped

2. 执行命令清理之前的残留容器和网络配置：
   docker-compose down -v
3. 重新启动Kafka相关服务：
   docker-compose up -d
4. 等待10秒左右待Kafka完成初始化，再启动Spring Boot测试应用即可正常连接。

• 端口映射改为"9092:9092"后，宿主机9092端口的流量会直接转发到Kafka容器内部的9092端口，解决端口不通的基础问题。
• KAFKA_LISTENERS配置为绑定0.0.0.0:9092，是让Kafka进程在容器内监听所有网卡的9092端口，避免容器内部网络拦截访问请求。
• KAFKA_ADVERTISED_LISTENERS配置为127.0.0.1:9092，是明确告知所有连接到Kafka的客户端，后续和Broker通信统一使用该地址，和你Spring应用中配置的bootstrap.servers=localhost:9092完全匹配，不会出现地址路由错误。
• 关闭自动创建Topic开关，是因为你代码中已经通过NewTopic Bean声明了toAll主题，避免两边配置的分区、副本数不一致引发额外异常。

该配置仅适配本地宿主机运行的应用连接Kafka的场景，如果后续需要让其他Docker容器内的服务接入该Kafka实例，需要额外增加容器内部通信的监听器规则。

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