Hi I'm trying to run the kafka-word-count example in spark2.9.1. I
encountered some exception when initialize kafka consumer/producer config.
I'm using scala 2.10.3 and used maven build inside spark streaming kafka
library comes with spark2.9.1. Any one see this exception before?
Thanks,
producer:
[java] The args attribute is deprecated. Please use nested arg
elements.
[java] Exception in thread "main" java.lang.NoClassDefFoundError:
scala/Tuple2$mcLL$sp
[java] at
kafka.producer.ProducerConfig.<init>(ProducerConfig.scala:56)
[java] at
com.turn.apache.KafkaWordCountProducer$.main(HelloWorld.scala:89)
[java] at
com.turn.apache.KafkaWordCountProducer.main(HelloWorld.scala)
[java] Caused by: java.lang.ClassNotFoundException:
scala.Tuple2$mcLL$sp
[java] at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
[java] at java.security.AccessController.doPrivileged(Native
Method)
[java] at
java.net.URLClassLoader.findClass(URLClassLoader.java:190)
[java] at java.lang.ClassLoader.loadClass(ClassLoader.java:306)
[java] at
sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
[java] at java.lang.ClassLoader.loadClass(ClassLoader.java:247)
[java] ... 3 more
[java] Java Result: 1