ClassNotFoundException 与 Kafka Connect MQTT 连接器

Question

我正在尝试使用 kafka connect 订阅 mqtt 主题，为此我使用了这个连接器：https://github.com/johanvandevenne/kafka-connect-mqtt. I followed the steps described there with a little modification and everything seemed to work. However, when I start the connector I get a ClassNotFoundException（屏幕截图）并且连接器停止了。好像是IMqttMessageListener传过来的，不知道怎么解决

对我能做什么有什么想法吗？

这是我的源文件：

connector.class : be.jovacon.kafka.connect.MQTTSourceConnector
mqtt.broker : tcp://localhost:1883
mqtt.clientID: 1
mqtt.topic : test
kafka.topic: timestamp
key.converter:org.apache.kafka.connect.storage.StringConverter
key.converter.schemas.enable:false
value.converter:org.apache.kafka.connect.storage.StringConverter
value.converter.schemas.enable:false

Answer 1

您需要将 /target/kafka-connect-mqtt-1.0-0-package/share/kafka-connect-mqtt 复制到您的 plugin.path，您可以在 worker's configuration file 中找到您的配置。

将 JAR 复制到 plugin.path 后，确保重新启动 Kafka Connect。

有关如何安装 Connect 插件的详细信息，请参阅 Confluent's Documentation。

Answer 2

您需要将/kafka-connect-mqtt/target/kafka-connect-mqtt-1.1.0-package/kafka-connect-mqtt/目录下的6个jar包全部复制过来。您的路径可能与您正在关注的存储库的自述文件中提到的路径不同。

ClassNotFoundException 与 Kafka Connect MQTT 连接器

ClassNotFoundException with Kafka Connect MQTT connector

java

mqtt

apache-kafka

apache-kafka-connect