1

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

systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory
systems.kafka.samza.msg.serde=byte
systems.kafka.consumer.auto.offset.reset=largest
systems.kafka.consumer.zookeeper.connect=localhost:2181/
systems.kafka.producer.bootstrap.servers=localhost:9092

それでも、プログラムを実行すると、例外が発生し続けます。 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が、誰かが以前にこの例外に陥った可能性があります。どんな助けでも大歓迎です！

4

1 に答える 1

1

ビルドに次のいずれかの問題があるようです。

  • クラスパスに Kafka jar (例: org.apache.kafka_kafka_.jar) がありません

  • クラス パス内の Kafka jar のバージョンは、getAdmin期待されているものと互換性がありません

  • おそらく 2 つのバージョンの Kafka jar (1 つの正しいバージョンと 1 つの不適切なバージョン) があり、JVM は間違ったバージョンを取得しています (ここでの修正は、ビルド内の不適切なバージョンを除外することです)。

于 2019-10-12T15:02:07.760 に答える