Docker容器中Kafka无法连接，求配置排查建议

核心问题：Docker端口未映射 #

你的Docker运行命令没有将容器内的Kafka外部监听端口（9093）映射到主机端口，导致主机上的Python代码无法访问容器内的服务。

具体修复步骤 #

1. 修正Docker运行命令，添加端口映射 #

先停止并删除旧容器，再执行带端口映射的启动命令：

docker stop kafka-broker && docker rm kafka-broker
docker run --name kafka-broker --env-file ./container-env.env -p 9093:9093 -d bitnami/kafka:latest

参数说明：-p 9093:9093 实现主机端口与容器端口的绑定，让主机可以通过localhost:9093访问容器内的Kafka服务。

2. 清理.env中的重复配置 #

你的.env文件中重复定义了KAFKA_BROKER_ID=1（第1行和第11行），虽然不影响功能，但建议删除其中一行，保持配置文件简洁。

3. 优化Python代码的异步逻辑与错误处理 #

原代码没有处理Kafka AdminClient的异步操作，且缺少错误捕获，容易出现无意义的阻塞或无法定位问题。调整后的代码如下：

from kafka.admin import AdminClient, NewTopic

# 初始化AdminClient
client = AdminClient(conf={"bootstrap.servers": "localhost:9093"})
topic_name = "test-topic"

# 定义新Topic
new_topic = NewTopic(
    topic=topic_name,
    num_partitions=1,
    replication_factor=1,
)

# 处理Topic创建的异步请求
try:
    create_futures = client.create_topics(new_topics=[new_topic])
    # 等待创建完成，设置30秒超时
    create_futures[topic_name].result(timeout=30)
    print(f"Topic [{topic_name}] 创建成功")
except Exception as e:
    print(f"创建Topic失败：{str(e)}")
    exit(1)

# 检查Topic是否存在
cluster_metadata = client.list_topics()
topic_exists = topic_name in cluster_metadata.topics
print(f"Topic [{topic_name}] 存在状态：{topic_exists}")

说明：

• 调用result()等待异步创建操作完成，避免提前进入检查逻辑
• 添加异常捕获，能直接输出连接失败、权限问题或Topic已存在等具体错误
• 简化Topic存在检查的逻辑

验证方法 #

容器启动后，先通过以下命令测试端口是否可达：

telnet localhost 9093

如果能正常连接，再运行调整后的Python代码即可正常创建Topic。

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