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

Reply via email to