微服务与Kafka端口映射异常问题排查求助

问题根源 #

错误日志显示客户端尝试连接localhost/127.0.0.1:9093，核心问题出在Kafka的KAFKA_ADVERTISED_LISTENERS配置：
当Spring Boot应用通过主机的localhost:9092连接到Kafka容器后，Broker会把advertised.listeners里的地址返回给客户端，客户端就会尝试直接连接这个地址。但你配置的PLAINTEXT://localhost:9093是容器内部的端口，主机并没有对外开放9093端口，自然连接失败。

解决方案 #

方案1：保留9092:9093映射，修正advertised.listeners #

修改docker-compose.yml中的Kafka环境变量，让advertised.listeners返回主机可访问的地址：

kafka:
  image: wurstmeister/kafka:2.13-2.7.0
  ports:
    - "9092:9093"
  environment:
    KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092  # 改为主机对外暴露的9092端口
    KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9093
    KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181

方案2：统一主机与容器端口（更直观） #

如果不需要跨端口映射，直接让主机端口和容器端口一致，配置更简单：

kafka:
  image: wurstmeister/kafka:2.13-2.7.0
  ports:
    - "9092:9092"
  environment:
    KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092
    KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092
    KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181

两种方案下，Spring Boot的配置都保持不变：

# Kafka general configuration
spring.kafka.bootstrap-servers=localhost:9092

验证操作 #

1. 停止并重启Kafka容器：

docker-compose down && docker-compose up -d

2. 启动Spring Boot应用，观察日志是否消除连接警告
3. 可选：用Kafka命令行工具测试连接：

kafka-topics.sh --list --bootstrap-server localhost:9092

核心原理 #

• KAFKA_LISTENERS：Kafka Broker在容器内部监听的端口，用于接收连接请求
• KAFKA_ADVERTISED_LISTENERS：Broker告诉客户端的连接地址，必须是客户端（你的Spring Boot应用）能直接访问到的地址，否则会出现客户端拿到错误地址导致连接失败的情况

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