为什么我无法连接到Docker部署的Kafka服务？

根因分析 #

你遇到的连接拒绝问题本质是Docker容器网络隔离导致的地址不匹配：

• 你的Web应用运行在独立的Docker容器中，配置的Kafka连接地址127.0.0.1:29092指向的是Web容器自身的本地网络，而非宿主机上运行的Kafka容器
• Kafka UI可以正常访问是因为它的配置中使用了正确的Kafka容器网络地址，且你从宿主机访问UI时用的是Docker映射到宿主机的8080端口，和Web应用的访问链路完全不同

具体修复步骤 #

• 第一步：确认你的docker-compose.yml中Kafka服务的服务名称，常见命名为kafka
• 第二步：检查Kafka服务的advertised.listeners配置，必须包含供容器内部访问的监听地址，示例配置如下：

  environment:
    KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092,PLAINTEXT_HOST://localhost:29092
    KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092,PLAINTEXT_HOST://0.0.0.0:29092
    KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
    KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
  

  上述配置中，kafka:9092是供同一Docker网络内的其他容器访问的地址，localhost:29092是供宿主机本地应用访问的地址
• 第三步：修改你的Web应用（NestJS服务）中Kafka客户端的连接配置，将brokers地址从127.0.0.1:29092改为Kafka服务名加内部端口，示例如下：

  @Module({
    imports: [
      KafkaModule.register({
        clientId: 'nestjs-consumer-server',
        brokers: ['kafka:9092'], // 替换为你的Kafka服务名+内部端口
      }),
    ],
  })
  

• 第四步：重启所有服务，执行docker-compose down && docker-compose up -d生效

连通性验证 #

修改配置后可以进入Web容器内部验证网络连通性：

1. 执行docker ps获取Web容器的ID
2. 进入容器：docker exec -it <你的Web容器ID> sh
3. 执行端口连通测试：nc -zv kafka 9092，返回succeeded即说明网络连通正常

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