Kafka Connect：在 Windows 上无法获取名称 org.osgi.framework.BundleListener 的类型答案

【问题标题】：Kafka Connect: could not get type for name org.osgi.framework.BundleListener on WindowsKafka Connect：在 Windows 上无法获取名称 org.osgi.framework.BundleListener 的类型
【发布时间】：2019-09-30 09:05:33
【问题描述】：

我正在关注用于 Linux 和 Windows 的 this tutorial。在 Step 7 我尝试运行时遇到 Java 异常：

>bin\windows\connect-standalone.bat config\connect-standalone.properties config\connect-file-source.properties config\connect-file-sink.properties

例外是：

[2019-05-13 13:00:20,145] WARN 无法获取名称类型来自任何类加载器的 org.osgi.framework.BundleListener (org.reflections.Reflections) org.reflections.ReflectionsException: 无法获取名称 org.osgi.framework.BundleListener 的类型在 org.reflections.ReflectionUtils.forName(ReflectionUtils.java:390) 在 org.reflections.Reflections.expandSuperTypes(Reflections.java:381) 在 org.reflections.Reflections.(Reflections.java:126) 在 org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.(DelegatingClassLoader.java:400) 在 org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanPluginPath(DelegatingClassLoader.java:299) 在 org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins(DelegatingClassLoader.java:237) 在 org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initPluginLoader(DelegatingClassLoader.java:185) 在 org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:178) 在 org.apache.kafka.connect.runtime.isolation.Plugins.(Plugins.java:61) 在 org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:78) 引起：java.lang.ClassNotFoundException： org.osgi.framework.BundleListener 在 java.net.URLClassLoader.findClass(URLClassLoader.java:381) 在 java.lang.ClassLoader.loadClass(ClassLoader.java:424) 在 sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) 在 java.lang.ClassLoader.loadClass(ClassLoader.java:357) 在 org.reflections.ReflectionUtils.forName(ReflectionUtils.java:388) ... 9 更多

我在 Windows 上工作。

【问题讨论】：

你解决了这个问题吗？
@MeganClerc 不，我只是离开它，拿了一台 Linux 机器。
您能分享一下如何使用 MongoDb 连接器安装 Kafka 的说明吗？
@MeganClerc 确定：mongodb.com/blog/post/…

标签： apache-kafka apache-kafka-connect

【解决方案1】：

所以我的 test.txt 文件中有 json 数据，并运行上述命令以在 test.sink.txt 文件中获取输出。我遇到了上面提到的相同错误，但是当我检查test.sink.txt 文件时，令人惊讶的是，json 数据是由 kafka 写入的。我在test.txt 文件中有一些不正确的 json 记录，并且在输出接收器文件中被省略了。

输入/输出文件的名称在本例中为test.txt/test.sink.txt，可以在我们在上述命令的参数中提供的属性文件中进行更改。

TLDR：即使 cmd 显示 stack-trace/warning ，该功能似乎也可以正常工作。数据从输入文件到主题输出文件。

【讨论】：