При потоковой передаче с использованием kafka я получаю сообщение об ошибке «Исключение в потоке» main »java.lang.NoSuchMethodError: org.apache.spark.internal.Logging. $ Init $"

Question

Я получаю сообщение об ошибке "Исключение в потоке" main "java.lang.NoSuchMethodError: org.apache.spark.internal.Logging. $ Init $" при запуске интеграции потоковой передачи искры с программой kafka в intellij в scala. код в порядке. Я дал версии также правильно. Можете ли вы, пожалуйста, кто-нибудь сказать мне проблему.

Я уже пробовал с разными версиями, и код не работает.

Я получаю ошибку в этом месте. ssc (streamingcontext):

val messages = KafkaUtils.createDirectStream[String, String](
  ssc,
  LocationStrategies.PreferConsistent,
  ConsumerStrategies.Subscribe[String, String](topicsSet, kafkaParams))

код должен работать без ошибок.