問題タブ [apache-samza]

質問する

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

81 問題
Newest
Active
Bountied
318
Unanswered
0 投票する
1 に答える
39 参照

scala - samza KafkaSystemFactory.getAdmin の例外

Scala で特定の Kafka トピックからメッセージを消費するために Samza を実行しています。実行するために、以下を含む samza-read.properties ファイルを作成しました。

それでも、プログラムを実行すると、例外が発生し続けます。 java.lang.NoClassDefFoundError: kafka/common/ReplicaNotAvailableException at org.apache.samza.system.kafka.KafkaSystemFactory.getAdmin(KafkaSystemFactory.scala:106)

これは対処する必要があると思いますsystems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactoryが、誰かが以前にこの例外に陥った可能性があります。どんな助けでも大歓迎です！


12345678910