创建KafkaAdminClient报KafkaConnectionError socket断开但KafkaConsumer正常

• 第一步：检查kafka-python依赖版本
  旧版本kafka-python（<2.0.0）的KafkaAdminClient对SSL协议的支持存在已知缺陷，而KafkaConsumer的SSL支持迭代更早更稳定，这是最常见的诱因。执行以下命令查看当前版本：
  pip show kafka-python
  如果版本低于2.0.0，执行升级命令即可解决多数同类问题：
  pip install --upgrade kafka-python

• 第二步：补全SSL相关配置参数
  部分版本的KafkaAdminClient不会默认复用系统或环境中的SSL证书配置，需要显式传入SSL相关参数，而KafkaConsumer对隐式配置的兼容更好。你可以根据你的集群SSL配置补充对应参数，示例如下：

admin_client = KafkaAdminClient(
    bootstrap_servers=bootstrap_servers, 
    client_id='test', 
    security_protocol="SSL",
    # 以下参数根据你的集群实际配置填写，不需要可以删除
    ssl_cafile="/path/to/ca.crt", # CA根证书路径
    ssl_certfile="/path/to/client.crt", # 客户端证书路径
    ssl_keyfile="/path/to/client.key", # 客户端私钥路径
    request_timeout_ms=30000 # 拉长超时时间，避免网络波动导致断开
)

• 第三步：核对集群ACL权限
  KafkaConsumer正常运行只需要主题级别的读权限，但KafkaAdminClient初始化时会主动请求集群控制器信息，需要对应SSL用户拥有集群级别的DESCRIBE权限。你可以联系Kafka集群管理员，确认当前SSL证书对应的用户是否配置了集群级别的访问权限。

• 第四步：开启Debug日志定位根因
  如果以上步骤都无法解决问题，可以开启kafka-python的debug日志查看详细的连接过程，定位是SSL握手失败、权限被拒还是其他网络问题：

import logging
logging.basicConfig(level=logging.DEBUG)

# 再执行你的KafkaAdminClient创建代码

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