通过 TLS 的 Kafka mqtt 连接器

Question

我需要帮助，因为我是 kafka 和 mqtt 的新手。我正在使用 docker compose 为 Mosquitto 代理和 Kakfa

之间的通信创建一个架构

我也在使用 confluent Kafka Connect MQTT 提供的连接器 (https://www.confluent.io/hub/confluentinc/kafka-connect-mqtt)

1883 端口通信效果很好但是当我尝试通过端口 8883 使用 MQTT 连接时，它失败了，因为它找不到任何证书。

有谁知道如何配置 Kafka Connect MQTT？需要什么样的证书（*.crt 不起作用）？

提前致谢，卢卡

Answer 1

这个问题有点老了，但由于我最近运行遇到了同样的问题，所以我把解决方案放在这里以防将来对某人有所帮助：

您必须使用 keytool 创建一个 TrustStore 文件并将您的证书放入其中：

keytool -import -file C:\cascerts\CA.cert -alias CA -keystore myTrustStore

系统将提示您设置信任库的密码。

然后在 MQTT 连接器属性文件中放入 SSL 配置：

# SSL
mqtt.ssl.trust.store.path=myTrustStore
mqtt.ssl.trust.store.password=password
mqtt.ssl.key.store.path=myTrustStore
mqtt.ssl.key.store.password=password

通过 TLS 的 Kafka mqtt 连接器

Kafka mqtt-connector over TLS

mqtt

apache-kafka

docker-compose