无法将 Kafka 连接到 InfluxDB Sink Connector

Question

我正在尝试将 Kafka 与 InfluxDB 连接起来。这是我的 InfluxSink.properties，基本上是连接器。

name=influxdb
connector.class=com.github.jcustenborder.kafka.connect.influxdb.InfluxDBSinkConnector
tasks.max=1
topics=influx
connect.influx.url=http://influxdb:8086
connect.influx.db=mydb
connect.influx.username=admin

但是当运行我的连接器时，我正面临这个 error!

ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectStandalone:126)
java.lang.NoClassDefFoundError: com/github/jcustenborder/kafka/connect/utils/VersionUtil
    at com.github.jcustenborder.kafka.connect.influxdb.InfluxDBSinkConnector.version(InfluxDBSinkConnector.java:41)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.versionFor(DelegatingClassLoader.java:387)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.versionFor(DelegatingClassLoader.java:392)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.getPluginDesc(DelegatingClassLoader.java:362)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanPluginPath(DelegatingClassLoader.java:334)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins(DelegatingClassLoader.java:268)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initPluginLoader(DelegatingClassLoader.java:216)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:209)
    at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)
    at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:78)
Caused by: java.lang.ClassNotFoundException: com.github.jcustenborder.kafka.connect.utils.VersionUtil
    at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:636)
    at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:182)
    at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:519)
    ... 10 more

如何消除这个错误。需要建议！提前致谢。

Answer 1

您没有正确安装连接器。最好的方法是从 Confluent Hub 下载并使用提供的 CLI 安装，或者将其解压缩到 Kafka Connect 插件文件夹中（如果需要，请更新 plugin.path）。

我相信 InfluxDB 连接器已被作者删除并替换为 this one。您可能会发现它的旧副本或原始存储库的分支，但请记住它们已经过时了好几年。

无法将 Kafka 连接到 InfluxDB Sink Connector

Failed to connect Kafka with InfluxDB Sink Connector

apache-kafka

kafka-consumer-api

apache-kafka-connect

influxdb

confluent-platform