Confluent Kafka创建Topic：PyCharm执行失败，Python终端正常

这个错误的核心是Kafka客户端在完成Topic创建操作前被强制销毁了，终端和PyCharm的执行环境差异是问题关键——终端里脚本会同步执行到完全结束，客户端有足够时间走完创建流程；但PyCharm中可能因为主线程提前退出，直接干掉了还在工作的客户端句柄。

下面是具体解决步骤：

1. 显式等待创建操作完成 #

调用create_new_topics后，必须等待异步操作的结果返回，不能让主线程提前结束。示例代码如下：

from confluent_kafka.admin import AdminClient, NewTopic

# 初始化AdminClient
admin_client = AdminClient({"bootstrap.servers": "localhost:9902,localhost:9903,localhost:9904"})

# 定义要创建的Topic
new_topics = [NewTopic("your_topic_name", num_partitions=3, replication_factor=2)]

# 发送创建请求并逐个等待结果
create_futures = admin_client.create_topics(new_topics)
for topic, future in create_futures.items():
    try:
        future.result()  # 阻塞等待操作完成
        print(f"Topic {topic} 创建成功")
    except Exception as e:
        print(f"创建Topic {topic} 失败: {str(e)}")

# 最后关闭客户端，确保所有操作收尾
admin_client.close()

2. 对齐PyCharm和终端的Python环境 #

• 检查PyCharm使用的解释器：打开File > Settings > Project: [你的项目名] > Python Interpreter，对比终端里python --version和pip list的结果，确保两个环境的confluent-kafka版本一致，避免依赖版本差异导致问题。
• 关闭“Run with Python console”：如果运行配置里开启了这个选项，可能会干扰主线程生命周期，取消勾选后重新测试。

3. 验证Kafka监听配置（可选排查） #

虽然终端能正常运行说明监听基本没问题，但可以确认下Kafka节点的server.properties：

• 确保listeners配置包含PLAINTEXT://localhost:9902（对应节点端口），避免节点绑定外部IP但客户端用localhost访问出现连接异常。
• 重启集群后，用命令kafka-topics.sh --list --bootstrap-server localhost:9902验证集群连通性，确保客户端能正常访问。

4. 升级Confluent Kafka Python版本 #

旧版本客户端可能存在异步操作的生命周期bug，执行pip install --upgrade confluent-kafka升级到最新稳定版，大概率能解决这类奇怪的句柄终止问题。

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