Confluent CLI向Confluent Cloud生产消息无响应卡住，消费正常求助

• 检查生产命令参数与配置文件
  确认bootstrap-server是Confluent Cloud提供的正确地址，api-key、api-secret无拼写错误，目标主题存在且名称正确。如果使用配置文件，确保producer.properties包含完整的安全配置：

  sasl.mechanism=PLAIN
  security.protocol=SASL_SSL
  sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="<你的API_KEY>" password="<你的API_SECRET>";
  

  完整生产命令示例：

  kafka-console-producer.sh --bootstrap-server <BOOTSTRAP_SERVER> --topic <TOPIC_NAME> --producer.config producer.properties
  

• 排查网络连通性
  消费正常不代表生产路径无问题，用nc -zv <BOOTSTRAP_SERVER> 9092测试端口连通性。如果是企业内网，需确认出站9092端口已开放，若使用代理，要在生产者配置里添加代理参数：

  proxy.host=<代理地址>
  proxy.port=<代理端口>
  

• 开启生产者调试日志
  给生产命令添加--debug all参数获取详细日志，从中定位连接超时、认证失败或权限错误：

  kafka-console-producer.sh --bootstrap-server <BOOTSTRAP_SERVER> --topic <TOPIC_NAME> --producer.config producer.properties --debug all
  

• 检查主题权限与状态
  登录Confluent Cloud控制台，确认当前API Key拥有目标主题的Write权限；同时检查主题分区是否正常，无Under Replicated状态的分区，这类异常会导致生产者无法写入消息。

• 验证客户端版本兼容性
  Confluent Cloud要求客户端版本与平台版本匹配（如Confluent 7.x对应Kafka 3.x），旧版本客户端可能因协议不兼容导致连接后卡住，建议升级到官方推荐的客户端版本。

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