java.lang.NoClassDefFoundError running example streaming.DirectKafkaWordCount

39 Views Asked by At

I am trying to run an example program DirectKafkaWordCount using this command:

bin/run-example --packages "org.apache.kafka:kafka-clients:3.6.1,org.apache.spark:spark-streaming-kafka_2.11:1.6. 3,org.apache.spark:spark-streaming-kafka-0-10_2.13:3.5.0" streaming.DirectKafkaWordCount localhost:9092 consumer -group quickstart-events

I get Exception in thread "main" java.lang.NoClassDefFoundError: scala/$less$colon$less at org.apache.spark.examples.streaming.DirectKafkaWordCount$.main(DirectKafkaWordCount.scala:70)

Can you please let me know what I am missing?

0

There are 0 best solutions below