Docker容器化Kafka Producer连接被拒绝问题求助

1. 先盯紧Python脚本的Producer配置 #

• 得确保代码里的bootstrap.servers确实改成了broker:29092（29092是Docker内部通信端口，9092是给本地外部用的），示例代码：

from kafka import KafkaProducer
import json

producer = KafkaProducer(
    bootstrap_servers=['broker:29092'],
    value_serializer=lambda v: json.dumps(v).encode('utf-8')
)

• 仔细排查脚本里有没有硬编码localhost:9092的地方，比如配置文件没生效、代码里直接写死了地址，别光改一处漏了其他地方。

2. 确认Docker Compose里Kafka的配置 #

Kafka容器必须正确设置KAFKA_ADVERTISED_LISTENERS，让内部容器能通过broker:29092访问，参考配置：

services:
  broker:
    image: confluentinc/cp-kafka:latest
    ports:
      - "9092:9092"  # 本地机器外部访问用的端口
      - "29092:29092" # Docker容器之间通信的端口
    environment:
      KAFKA_BROKER_ID: 1
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://broker:29092,PLAINTEXT_HOST://localhost:9092
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
      KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
  zookeeper:
    image: confluentinc/cp-zookeeper:latest
    environment:
      ZOOKEEPER_CLIENT_PORT: 2181
      ZOOKEEPER_TICK_TIME: 2000
  data:
    build: ./your-python-script-folder # 或者用Python镜像挂载本地脚本
    depends_on:
      - broker
    volumes:
      - ./local-scripts:/app # 把本地脚本目录挂载到容器内

• 核心是KAFKA_ADVERTISED_LISTENERS，必须包含PLAINTEXT://broker:29092供容器间访问，PLAINTEXT_HOST://localhost:9092留给本地外部用。

3. 验证容器间的网络连通性 #

• 进入data容器，执行ping broker，看能不能解析到Kafka容器的IP，确认网络是通的：

docker exec -it <你的data容器名> ping broker

• 如果ping不通，检查Docker Compose的网络配置，默认同一compose里的服务会在同一个网络，要是自定义了网络，得确保data和broker在同一个网络组里。

4. 检查配置文件的加载逻辑 #

• 要是用了外部配置文件（比如.env、config.ini），得确保容器里能读到正确的配置，别挂载了本地的旧配置（里面还是localhost:9092）。可以把配置文件和脚本一起挂载到容器，或者在Dockerfile里直接COPY进去。

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