EC2部署Spring Boot+Kafka聊天功能遇TimeoutException求助

• 技术栈：Spring Boot + Kafka + React
• 本地（含Docker Compose环境）运行正常，EC2部署后浏览器客户端发送消息触发org.apache.kafka.common.errors.TimeoutException
• 已开放EC2入站规则中Kafka（默认9092）和Zookeeper（默认2181）端口

1. 修正Kafka的监听地址配置 #

这是EC2部署Kafka最常见的问题：Kafka默认会把容器内部地址暴露给客户端，导致外部无法连接。必须在Docker Compose中明确配置对外暴露的地址为EC2公网IP/域名：

services:
  kafka:
    image: wurstmeister/kafka:latest
    ports:
      - "9092:9092"
    environment:
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      # 对外暴露的地址（必须填EC2公网IP）
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://<你的EC2公网IP>:9092,PLAINTEXT_INTERNAL://kafka:29092
      # 监听所有网卡
      KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092,PLAINTEXT_INTERNAL://0.0.0.0:29092
      # 映射协议
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_INTERNAL:PLAINTEXT
      KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT_INTERNAL

• PLAINTEXT_INTERNAL用于容器内部（如Spring Boot容器和Kafka之间）的通信，PLAINTEXT用于外部客户端（React）连接。

2. 检查Spring Boot的Kafka配置 #

确保Spring Boot配置文件中指定的Kafka地址正确：

# application.properties
spring.kafka.bootstrap-servers=<你的EC2公网IP>:9092
# 若Spring Boot和Kafka在同一Docker Compose网络，也可使用内部地址：kafka:29092

3. 验证EC2网络连通性 #

• 入站规则：确认安全组允许9092端口的入站流量（测试阶段可临时设置为0.0.0.0/0，后续再限制IP范围）
• 出站规则：EC2实例自身需能访问公网IP的9092端口，部分VPC配置会限制实例访问自身公网IP，此时可给Kafka额外配置内网IP监听，让Spring Boot用内网IP连接，React用公网IP
• 本地连通性测试：在本地机器执行以下命令，确认端口可达：

  nc -zv <EC2公网IP> 9092
  # 或
  telnet <EC2公网IP> 9092
  

4. 确认Kafka日志中的监听地址 #

查看Kafka容器日志，确认对外暴露的地址正确：

[2024-xx-xx xx:xx:xx,xxx] INFO Registered broker 1 at path /brokers/ids/1 with addresses: PLAINTEXT://<你的EC2公网IP>:9092, PLAINTEXT_INTERNAL://kafka:29092 (kafka.zk.KafkaZkClient)

如果日志中显示的是容器内网IP（如172.x.x.x），说明KAFKA_ADVERTISED_LISTENERS配置错误，需重新修正。

5. 客户端（React）的配置与跨域处理 #

• 若React直接使用kafka-js连接Kafka，需确保bootstrapServers设置为<EC2公网IP>:9092
• 浏览器直接连接Kafka会存在跨域问题，更安全的方式是：React调用Spring Boot接口，由Spring Boot作为生产者发送消息到Kafka，避免客户端直接连接Kafka

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