I am getting error "Exception in thread "main" java.lang.NoSuchMethodError: org.apache.spark.internal.Logging.$init$" while running the spark streaming integration with kafka program in intellij in scala. the code is fine. I have given the versions also right. Can you please anyone tell me the problem.
I have already tried with different versions and the code is not working.
I am getting error at this place. ssc(streamingcontext):
val messages = KafkaUtils.createDirectStream[String, String](
ConsumerStrategies.Subscribe[String, String](topicsSet, kafkaParams))