Golang基于Confluent Kafka Docker部署时消费者无法连接求助

核心问题：Kafka监听器配置与客户端连接端口不匹配 #

从你的配置和错误日志来看，问题出在Kafka的对外通告监听器配置和客户端bootstrap.servers指定的端口不匹配，同时消费者容器的启动依赖逻辑存在疏漏。

1. 端口不匹配的具体原因 #

在Docker Compose的Kafka配置中：

KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092

• PLAINTEXT://kafka:29092：Docker容器集群内部通信的专属监听器，容器内的服务必须用这个地址连接Kafka
• PLAINTEXT_HOST://localhost:9092：仅用于宿主机外部访问Kafka的监听器

你的消费者和生产者配置中，bootstrap.servers错误使用了kafka:9092——这个端口在Kafka容器内部并未绑定容器间通信的监听器，因此触发连接拒绝。日志中出现的GroupCoordinator: localhost:9092连接失败，是因为Kafka将宿主机监听地址返回给了消费者，但消费者容器内的localhost指向自身而非Kafka容器，自然无法连通。

2. 修复步骤 #

步骤一：修正客户端bootstrap.servers配置

将消费者和生产者的连接地址统一改为容器内部通信的kafka:29092，移除多余的无效地址：

消费者配置修正后：

c, err := kafka.NewConsumer(&kafka.ConfigMap{
    "bootstrap.servers": "kafka:29092",
    "group.id":          "myGroup",
    "auto.offset.reset": "earliest",
})

生产者配置修正后：

p, err := kafka.NewProducer(
    &kafka.ConfigMap{"bootstrap.servers": "kafka:29092"},
)

步骤二：修正消费者容器的依赖配置

当前消费者容器calculator仅依赖receiver，未依赖kafka，可能导致消费者启动时Kafka还未完全就绪。修改Docker Compose中的消费者配置：

calculator:
  build:
    context: ./distance_calculator/
    dockerfile: ./Dockerfile
  restart: always
  depends_on:
    - receiver
    - kafka  # 添加对Kafka的依赖，确保Kafka优先启动完成

步骤三：验证Kafka端口映射

无需修改Kafka容器的端口映射，29092是容器内部通信端口，容器间通过服务名+内部端口即可直接通信，宿主机端口映射不影响容器集群内部的网络交互。

3. 额外说明 #

• 生产者之前偶发可用是因为启动时Kafka的宿主机监听器刚好就绪，但这不是正确的容器化配置，必须统一使用容器内部的监听器地址。
• 非容器环境下正常是因为你使用了localhost:9092，对应宿主机的Kafka监听端口，和容器环境的网络逻辑完全不同。

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