我正在学习这个教程，它同时适用于linux和windows。在步骤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]警告无法从任何类加载器（org.reflections.reflections）org.reflections.reflections获取名称org.osgi.framework.bundlelistener的类型异常：无法从org.reflections.reflectionutils.forname（reflectionutils）获取名称org.osgi.framework.bundlelistener的类型。java:390)在org.reflections.reflections.expandsupertypes（反射）。java:381)在org.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。java:61)在org.apache.kafka.connect.cli.connectstandalone.main（connectstandalone。java:78)原因：java.lang.classnotfoundexception:org.osgi.framework.bundlelistener at 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（类加载器。java:357)位于org.reflections.reflectionutils.forname（reflectionutils。java:388) ... 9个以上
我在修Windows。
1条答案
按热度按时间c90pui9n1#
所以我的数据库里有json数据
test.txt文件并运行上述命令以获取输出test.sink.txt文件。我面临着上述同样的错误，但当我检查test.sink.txt令人惊讶的是，json数据是由kafka编写的。我几乎没有json记录test.txt输出接收器文件中不正确且被忽略的文件。输入/输出文件的名称，在本例中是
test.txt/test.sink.txt可以在我们在上面命令的参数中给出的属性文件中更改。tldr：尽管cmd显示堆栈跟踪/警告，但功能似乎正在工作。数据从输入文件到主题再到输出文件。