独立模式下的Kafka mqtt连接器错误答案

【问题标题】：Kafka mqtt connector error in stand alone mode独立模式下的Kafka mqtt连接器错误
【发布时间】：2021-10-15 05:20:55
【问题描述】：

我有一个在 ubuntu 上运行的 MQTT 代理和 Kafka 代理。我可以通过生产者向 Kafka 控制台消费者发布消息。但是，当我尝试通过此存储库 https://github.com/SINTEF-9012/kafka-mqtt-source-connector 在独立模式下通过连接器在 Kafka 上发布消息时，会引发以下错误：

这些是配置

connect-standalone.properties 文件：

源 connector.properties 文件：

请帮助我将 mosquitto 连接到 Kafka。

【问题讨论】：

请不要发布文字图片，它们很难阅读，对于屏幕阅读器的用户来说是不可能的。发布实际文本并使用工具栏对其进行格式化。

标签： apache-kafka apache-kafka-connect mosquitto

【解决方案1】：

错误表明在 POM 中声明的这种依赖关系不是您放在插件路径中的 JAR 的一部分

    <dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-api</artifactId>
        <version>2.10.0</version>
    </dependency>

看日志，好像用的是SNAPSHOT这个jar文件，不是with-dependencies那个

【讨论】：

我尝试添加 jar 文件 with-dependencies 然后重新启动两个代理。当命令 _mosquitto_pub -h 127.0.0.1 -p 1883 -t test -m "Hey" _ 时，它在 MQTTSourceConnectorTask 处给我一个错误。 **错误 MqttSourceConnectorTask org.bson.json.JsonParseException：JsonReader 期待一个值，但发现“嘿”**
错误似乎是自描述的。您发送了-m "Hey"，但您有value.converter 期待JSON，而不是纯字符串。例如，尝试-m '{"msg":"Hey"}'
您好，感谢您的及时回复。我也试过这个，但它给了我同样的错误。有什么建议我缺少什么？
在这种情况下，我认为您不应该得到包含 but found 'hey' 的完全相同的错误。我没有使用此连接器的经验来真正进一步回答。如果改成 StringConverter 不起作用，那么我建议打开一个 github 问题或尝试使用源代码 set up a debugger
我尝试了 evokly 连接器，因为我必须在独立模式下使用。感谢您的回复。