我想为ApacheKafka流编写一个小测试程序。到目前为止我所做的是：
安装intellij。
从git复制源代码。
跑 gradle wrapper 以及 gradle idea 在解压文件夹中。
导入intellij中的文件夹。
在streams/examples/src/main/java/…下创建新的java类。
跑 gradlew jar 复制examples/build/libs/中的.jar文件。。。到服务器。
现在我想运行它。我试过了 java -cp kafka.jar *Class* 但是，我只有一个例外：
Error: A JNI error has occurred, please check your installation and try again
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/kafka/streams/kstream/ValueMapper
at java.lang.Class.getDeclaredMethods0(Native Method)
at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)
at java.lang.Class.privateGetMethodRecursive(Class.java:3048)
at java.lang.Class.getMethod0(Class.java:3018)
at java.lang.Class.getMethod(Class.java:1784)
at sun.launcher.LauncherHelper.validateMainClass(LauncherHelper.java:544)
at sun.launcher.LauncherHelper.checkAndLoadMain(LauncherHelper.java:526)
Caused by: java.lang.ClassNotFoundException: org.apache.kafka.streams.kstream.ValueMapper
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)有人知道我做错了什么吗？我需要一些适当的指示。
1条答案
按热度按时间gdrx4gfi1#
首先，您只需在intellij中运行应用程序—无需组装jar并将此jar复制到任何服务器。
复制examples/build/libs/中的.jar文件。。。到服务器。
你说的“服务器”是什么意思？如果你提到经纪人，这不是必需的。你可以在任何你喜欢的地方运行你的应用程序。不需要（也不建议）在与代理相同的服务器上运行streams应用程序。
此外，没有理由下载整个kafka源代码（当然，您需要二进制文件来启动代理，但是如果您已经部署了kafka集群，您可以跳过这个）。更好的方法是启动一个新的空项目，然后将依赖项添加到
kafka-streams（就像您希望在项目中使用的任何其他库一样）。本快速入门指南：http://docs.confluent.io/current/streams/quickstart.html
您还可以查看以下示例：https://github.com/confluentinc/examples/tree/3.1.x/kafka-streams