Windows环境下Spring应用无法连接Docker中的Kafka Broker

核心问题分析 #

你遇到的连接断开、Topic元数据超时问题，根源是Windows Docker Desktop环境下，wurstmeister/kafka镜像的默认网络配置与外部客户端（Spring Boot应用）的访问逻辑不匹配：Kafka Broker启动后会向客户端返回容器内部的IP地址，而外部主机无法直接访问该地址，导致连接中断、元数据获取失败。

修复步骤 #

1. 修改docker-compose.yaml配置 #

替换原有Kafka的环境变量配置，添加双监听器规则，区分容器内部与外部主机的访问地址：

version: '2'
services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"
  kafka:
    image: wurstmeister/kafka
    ports:
      - "9092:9092"
    environment:
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_CREATE_TOPICS: "Topic1:1:3"
      # 核心修复：配置双监听器适配Windows Docker网络
      KAFKA_ADVERTISED_LISTENERS: INSIDE://kafka:9093,OUTSIDE://localhost:9092
      KAFKA_LISTENERS: INSIDE://0.0.0.0:9093,OUTSIDE://0.0.0.0:9092
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INSIDE:PLAINTEXT,OUTSIDE:PLAINTEXT
      KAFKA_INTER_BROKER_LISTENER_NAME: INSIDE

2. 重启Kafka集群 #

执行以下命令重新部署容器：

# 停止并删除现有容器
docker-compose down
# 启动新配置的容器
docker-compose up -d

3. 验证Topic是否存在 #

进入Kafka容器验证Topic1是否被正确创建：

# 进入Kafka容器
docker exec -it <kafka-container-id> /bin/sh
# 列出所有Topic
kafka-topics.sh --list --bootstrap-server localhost:9093

（替换<kafka-container-id>为实际的容器ID，可通过docker ps查看）

4. 修复消费者日志的小问题 #

你的消费者代码中日志格式化存在错误，会导致日志无法正确显示消息内容，修改如下：

@KafkaListener(topics = "Topic1", groupId = "myGroup")
public void getMessage(String message){
  logger.info(String.format("consumed message %s", message));
}

5. 重启Spring Boot应用 #

完成上述配置后，重启你的Spring Boot应用，再次调用API发送消息即可正常连接。

配置说明 #

• KAFKA_LISTENERS：指定Kafka监听的端口和协议，INSIDE用于容器内部Broker间通信，OUTSIDE用于外部主机访问
• KAFKA_ADVERTISED_LISTENERS：Kafka返回给客户端的连接地址，内部服务用kafka:9093，外部主机用localhost:9092
• KAFKA_INTER_BROKER_LISTENER_NAME：指定Broker之间通信使用内部监听器，避免外部网络干扰

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