【发布时间】：2019-11-28 00:56:50
【问题描述】：
我需要帮助，因为我是 kafka 和 mqtt 的新手。 我将尝试简要解释我正在使用的架构。 我正在使用 Confluent 5.3.1 平台，并配置了一个连接器（源 mqtt 连接器），它将数据从 mqtt 代理传输到 kafka 代理。 为了连接到 mqtt 代理，我需要一个 Json Web 令牌，但我不知道该怎么做。我已阅读 Confluent 文档，但找不到任何可能的解决方案。 有人可以帮我吗？
【问题讨论】：
【发布时间】：2019-11-28 00:56:50
【问题描述】：
查看文档for the connector 看起来它只支持基于密码的身份验证，而不支持 JWT。
【讨论】：
-
我阅读了这份文档 (docs.confluent.io/current/connect/security.html)，似乎可以做些什么（我错了吗？）但我无法实现。
-
这是对 Kafka Connect 集群本身的身份验证，而您的问题是关于对 MQTT 代理的身份验证。
-
好的，谢谢。因此，mqtt 源连接器只允许设置密码和用户名以连接到 mqtt 代理，但不能使用 IDP 来执行此操作。对吗？
-
这是我的理解，是的。
-
只是好奇：我需要使用 websocket 协议设置字段 mqtt.server.uri。所以我有类似 ws://
:port 的东西。我观察到它可能不起作用，因为我无法读取数据。有可能解决这个问题吗？