Apache Kafka Streamsのための小さなテストプログラムをプログラムしたいと思います。私がこれまで行ってきたのは、Apache Kafka Streamsビルドと開始jar
- Intellijをインストールします。
- gitのソースコードをコピーします。
- unzipedフォルダに
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)
誰かが私が間違って何をやったか知っていますか?私は適切な指示が必要です。
あなたはhttps://github.com/confluentinc/下カフカストリームの例で見たいと思うかもしれません例(フォルダ 'kafka-streams')。いくつかのデモアプリケーションとエンドツーエンドの統合テスト(埋め込まれたカフカクラスタが生成されるため、その場合は何もインストールする必要はありません)があります。これらの例を使って、ビルド設定( 'kafka-streams/pom.xml'参照)を含め、セットアップを理解するだけでなく、独自のアプリケーションを作成するためのテンプレートとして使用することもできます。 –