本地Python客户端无法连接Docker容器中Kafka的问题求助

按以下步骤排查修复：

1. 先确认Kafka服务状态 #

• 执行 docker-compose ps，确保kafka和zookeeper容器状态均为Up
• 查看Kafka启动日志：docker logs kafka，日志出现started (kafka.server.kafkaServer)说明服务正常；若有ZooKeeper连接错误，先确保ZooKeeper正常启动

2. 修正Kafka监听配置（核心问题） #

你的docker-compose.yml中Kafka的KAFKA_ADVERTISED_LISTENERS配置存在访问适配问题：

• 若用本机Docker，当前PLAINTEXT_HOST://localhost:29092没问题；若为WSL2、虚拟机或远程Docker，localhost无法指向宿主机IP，需替换成宿主机实际IP（如192.168.3.10），测试环境也可临时用0.0.0.0
• 配置里重复了KAFKA_INTER_BROKER_LISTENER_NAME，删除冗余行

修正后的kafka服务配置片段：

kafka:
  image: confluentinc/cp-kafka:latest
  container_name: kafka
  depends_on:
    - zookeeper
  ports:
    - 29092:9092
  environment:
    KAFKA_BROKER_ID: 1
    KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
    KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092,PLAINTEXT_HOST://192.168.3.10:29092  # 替换为你的宿主机IP
    KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
    KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
    KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1

3. 调整Python Producer代码 #

• 确保导入json模块（代码中用了dumps，未导入会报错）
• 移除api_version参数，让客户端自动与Kafka协商版本（新版库无需手动指定）
• 若替换了宿主机IP，bootstrap_servers要对应修改

修正后的Producer代码：

from kafka import KafkaProducer
import json

producer = KafkaProducer(bootstrap_servers=['192.168.3.10:29092'],  # 对应宿主机IP
                         value_serializer=lambda x: 
                         json.dumps(x).encode('utf-8'))

producer.send('demo_test', value={'surname':'paramar'})
producer.flush()

4. 测试网络连通性 #

在本地终端执行：

nc -zv localhost 29092  # 或替换为你的宿主机IP

显示succeeded!说明端口连通；若不通，检查防火墙是否放行29092端口，或Docker端口映射是否生效

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