Kafka消息发送超时问题：Docker+Spring Kafka遇TimeoutException

1. Docker Kafka监听配置错误（最常见原因） #

Docker部署的Kafka如果监听地址配置不当，外部Spring应用会无法正常与Broker建立通信，这是导致超时的核心原因之一。

检查Docker Compose的Kafka环境变量 #

确保KAFKA_ADVERTISED_LISTENERS同时包含外部可访问地址和Docker内部通信地址：

kafka:
  image: wurstmeister/kafka:latest
  ports:
    - "9092:9092"
  environment:
    KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092,PLAINTEXT_INTERNAL://kafka:29092
    KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092,PLAINTEXT_INTERNAL://kafka:29092
    KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_INTERNAL:PLAINTEXT
    KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT_INTERNAL
    KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181

• KAFKA_LISTENERS：用0.0.0.0允许Kafka监听所有IP端口，避免被限制在Docker内部
• KAFKA_ADVERTISED_LISTENERS：必须包含外部应用能解析的地址（比如本地用localhost:9092，服务器部署则填服务器公网IP:9092），如果只配置kafka:29092这类内部别名，外部Spring应用会无法找到Broker

2. Spring Kafka生产者配置不匹配 #

检查Spring配置文件（application.yml/properties）中的生产者参数：

spring.kafka.bootstrap-servers=localhost:9092
spring.kafka.producer.acks=all
spring.kafka.producer.retries=3

• bootstrap-servers必须和Docker Kafka的KAFKA_ADVERTISED_LISTENERS中的外部地址完全一致
• 如果设置了acks=all，要确保主题Robs的副本配置正常：进入Kafka容器执行命令查看主题状态：

  kafka-topics.sh --describe --topic Robs --bootstrap-server localhost:9092
  

  若ReplicationFactor为1但Broker正常，没问题；如果是多Broker集群，需确认Isr列包含可用的Broker ID，否则生产者会等待确认超时。

3. 主题Robs状态异常 #

• 若主题未手动创建，Kafka默认自动创建（需开启auto.create.topics.enable=true），但自动创建的主题默认分区/副本数为1，若Broker启动未完成就发送消息，可能导致短暂超时。可手动创建主题避免此问题：

  kafka-topics.sh --create --topic Robs --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092
  

• 若主题已存在，检查分区是否可用：上面的describe命令中，Isr列不能为空，否则说明分区处于不可用状态，生产者无法发送消息。

4. 网络连通性问题 #

• 测试Spring应用所在机器能否访问Kafka端口：

  # 用telnet测试
  telnet localhost 9092
  # 或用nc工具
  nc -zv localhost 9092
  

  若连接失败，检查Docker Compose的端口映射是否正确（9092:9092），以及本地防火墙是否开放了9092端口。
• 若Spring应用也在Docker容器中，需确保两者处于同一个Docker网络，或使用Kafka的内部别名kafka:29092作为bootstrap-servers地址。

5. 超时配置辅助排查 #

错误日志中的120000 ms是默认的delivery.timeout.ms，说明生产者等待2分钟仍未收到Broker响应。可临时缩短超时时间快速验证问题：

spring.kafka.producer.properties.delivery.timeout.ms=30000

若调整后仍超时，说明不是时间不足，而是根本未与Broker建立有效连接。

日志分析关键点 #

查看Spring应用日志，若存在Could not resolve server address或Connection refused字样，直接指向连接问题；若只有TimeoutException，大概率是Kafka监听配置错误，导致Broker无法将响应返回给生产者。

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