使用Kafdrop连接Confluent Cloud Kafka集群时遇超时问题求助

你遗漏了Confluent Cloud集群必需的SASL认证配置和SSL加密配置，具体需要补充以下参数到启动命令中：

• 启用SASL PLAIN认证：--kafka.saslMechanism=PLAIN
• 指定认证用户名（即Confluent Cloud的API Key）和密码（API Secret）：--kafka.saslJaasConfig=org.apache.kafka.common.security.plain.PlainLoginModule required username='<你的API Key>' password='<你的API Secret>';
• 启用SSL加密：--kafka.securityProtocol=SASL_SSL

完整的启动命令示例：

java -jar kafdrop-3.30.0.jar \
  --kafka.brokerConnect=你的集群地址.confluent.cloud:9092 \
  --kafka.securityProtocol=SASL_SSL \
  --kafka.saslMechanism=PLAIN \
  --kafka.saslJaasConfig="org.apache.kafka.common.security.plain.PlainLoginModule required username='<API_KEY>' password='<API_SECRET>';"

额外注意事项 #

• 替换命令中的<API_KEY>和<API_SECRET>为你在Confluent Cloud控制台创建的Kafka集群对应的API密钥对
• 确保当前网络可以访问Confluent Cloud的9092端口，部分环境可能需要调整防火墙规则

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