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?