Исключение на самзе KafkaSystemFactory.getAdmin - PullRequest
Новая
       28

Исключение на самзе KafkaSystemFactory.getAdmin

1 голос
/ 03 октября 2019

Я использую Samza, чтобы получать сообщения из заданной темы Кафки в Scala. Для запуска я создал файл 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, но, возможно, кто-то уже сталкивался с этим исключением. Любая помощь с благодарностью!

1 Ответ

1 голос
/ 12 октября 2019

Похоже, у вас есть одна из следующих проблем с вашей сборкой:

  • В вашем пути к классу отсутствует файл Kafka (например, org.apache.kafka_kafka_.jar)

  • Версия фляги Кафки в вашем пути к классу несовместима с тем, что ожидает getAdmin

  • Возможно, у вас есть 2 версииKafka jar (один правильный + один неправильный) и JVM обнаруживает неправильный (исправление здесь, чтобы исключить плохую версию в вашей сборке)

...