Docker部署Kafka后无法接收消息且消费者组超时，求排查方案

1. 检查Kafka监听配置（核心问题点） #

Docker部署Kafka时，KAFKA_ADVERTISED_LISTENERS配置错误是导致客户端无法正常通信的最常见原因：

• 若客户端在Docker网络内（比如同网络的容器），需确保配置包含Kafka容器的hostname（通常是容器名）：

  KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092
  KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092
  

• 若客户端在宿主机，需添加宿主机可访问的监听地址：

  KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092,PLAINTEXT_HOST://localhost:9093
  KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092,PLAINTEXT_HOST://0.0.0.0:9093
  KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
  

  容器内客户端用kafka:9092连接，宿主机客户端用localhost:9093。

2. 消费者组超时排查 #

创建消费者组超时本质是客户端与broker连接异常：

• 验证消费者bootstrap.servers配置：Docker网络内填kafka:9092，宿主机填localhost:9093，与监听配置对应。
• 查看Kafka容器日志定位问题：

  docker logs <kafka-container-id>
  

  搜索Connection to node -1、TimeoutException关键词，确认是否存在broker启动异常或ZK连接问题。

3. 验证消息是否真的写入Topic #

不要依赖生产者控制台的"发送成功"提示，用Kafka内置工具确认：

1. 进入Kafka容器：

   docker exec -it <kafka-container-id> /bin/sh
   

2. 直接读取Topic消息：

   kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning
   

• 若能读到消息：问题出在你的消费者客户端配置。
• 若读不到消息：检查生产者acks配置——若设为0，生产者不会等待broker确认就返回成功，实际消息可能未写入，建议改为1或all。

4. 客户端配置细节检查 #

• 消费者auto.offset.reset：新消费者组需设为earliest才能读取历史消息，默认latest只会接收启动后的新消息。
• 确认group.id无重复或冲突，Topic名称大小写完全匹配。

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