ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectDistributed) java.lang.NoClassDefFoundError: io/debezium/util/IoUtil

Question

Objective

我正在尝试使用 Debezium 连接器 (1.2.4.Final) 从 Kafka Connect（最好是分布式模式）连接到我的 Oracle Database(12c)。我使用的Kafka版本是2.13-2.6.0.

使用的命令

根据提到的 here，我是 运行 这个命令：

C:\Users\username\Downloads\kafka>bin\windows\connect-distributed.bat config\connect-distributed.properties

错误

我得到的错误是：

ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectDistributed) java.lang.NoClassDefFoundError: io/debezium/util/IoUtil at io.debezium.connector.oracle.Module.(Module.java:19) at io.debezium.connector.oracle.OracleConnector.version(OracleConnector.java:23) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.versionFor(DelegatingClassLoader.java:390) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.versionFor(DelegatingClassLoader.java:395) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.getPluginDesc(DelegatingClassLoader.java:365) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanPluginPath(DelegatingClassLoader.java:337) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins(DelegatingClassLoader.java:268) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.registerPlugin(DelegatingClassLoader.java:260) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initPluginLoader(DelegatingClassLoader.java:229) at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:206) at org.apache.kafka.connect.runtime.isolation.Plugins.(Plugins.java:61) at org.apache.kafka.connect.cli.ConnectDistributed.startConnect(ConnectDistributed.java:91) at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:78) Caused by: java.lang.ClassNotFoundException: io.debezium.util.IoUtil at java.net.URLClassLoader.findClass(URLClassLoader.java:382) at java.lang.ClassLoader.loadClass(ClassLoader.java:418) at org.apache.kafka.connect.runtime.isolation.PluginClassLoader.loadClass(PluginClassLoader.java:104) at java.lang.ClassLoader.loadClass(ClassLoader.java:351) ... 13 more

设置

在我的连接中-distributed.properties，我有这个：

plugin.path=C:/Users/username/Downloads/kafka/libs/debezium

在 debezium 文件夹中（根据 this question 中评论中 Gunnar 的推荐），我有这些罐子：

我还在%PATH%中添加了插件路径如下：

echo %PATH% | findstr debezium

XXX;C:\Users\username\Downloads\kafka\libs\debezium;

帮助

任何帮助将不胜感激，因为我希望用这个 debezium 连接器替换我的数据库轮询，这似乎是更好的方法。谢谢！

Answer 1

Gunnar here 的解决方案有效！ （他的解释也在那里，如果你想看看的话。）

plugin.path=C:\Users\username\Downloads\kafka\libs

这也有效：

plugin.path=C:/Users/username/Downloads/kafka/libs
plugin.path=C:\Users\username\Downloads\kafka\libs
plugin.path=/Users/username/Downloads/kafka/libs

错误是：plugin.path 应该取决于 libs 而不是 libs/debezium