samza 异常 KafkaSystemFactory.getAdmin

Question

我运行宁 Samza 在 Scala 中使用给定 Kafka 主题的消息。为了运行，我创建了一个 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 但也许有人以前遇到过这个异常。非常感谢任何帮助！

Answer 1

看起来您的构建存在以下问题之一：

您的 class 路径中缺少 Kafka jar（例如：org.apache.kafka_kafka_.jar）
您的 class 路径中的 Kafka jar 版本与 getAdmin 所期望的不兼容
您可能有 2 个版本的 Kafka jar（一个正确 + 一个不正确）并且 JVM 正在选择不正确的版本（此处修复是为了排除构建中的错误版本）

samza 异常 KafkaSystemFactory.getAdmin

Exception on samza KafkaSystemFactory.getAdmin

scala

apache-kafka

apache-samza