FWIW I have been running into the same problem when trying to write a Storm topology in Scala 2.9.1 that reads from a Kafka 0.7.2 cluster.
See the following JIRA tickets for more information: https://issues.apache.org/jira/browse/KAFKA-139 https://issues.apache.org/jira/browse/KAFKA-134 I also have been trying to build Kafka from trunk because code was added to support multiple versions of Scala, but it didn't work for me. After hours of troubleshooting I basically gave up trying to use Scala 2.9.x in combination with Kafka 0.7.2 or Kafka 0.8-trunk. My setup was: - Mac OS X and CentOS6 (tried on both) - Scala 2.9.1 - sbt 0.11.3 (also tried sbt 0.11.2) - Kafka 0.7.2 as it is downloadable from the Kafka homepage - Kafka 0.8-trunk from github - I used the Kafka Java API v0.7 as published at http://clojars.org/repo(storm::kafka::0.7.0-incubating), based on information in the Storm wiki Sorry for not providing much more than "me too" information, but even confirming negative results may be useful ;-) Best, Michael On Tue, Oct 30, 2012 at 5:07 PM, Hussein Baghdadi <hubaghd...@hotmail.com>wrote: > > Hi, > I cloned Kafka 0.8 and build it on my machine (OS X) > My project is built with Scala 2.9.2 . So in my build file I indicated > that Scala version is 2.9.2 > Upon trying to send a message to Kafka topic, I got: > Caused by: java.lang.NoClassDefFoundError: scala/Tuple2$mcLL$sp at > kafka.producer.ProducerConfig.<init>(ProducerConfig.scala:29) ... 31 > moreCaused by: java.lang.ClassNotFoundException: scala.Tuple2$mcLL$sp at > java.net.URLClassLoader$1.run(URLClassLoader.java:202) at > java.security.AccessController.doPrivileged(Native Method) at > java.net.URLClassLoader.findClass(URLClassLoader.java:190) at > java.lang.ClassLoader.loadClass(ClassLoader.java:306) at > sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) at > java.lang.ClassLoader.loadClass(ClassLoader.java:247) ... 32 more > Any idea what might going wrong? > Thanks for help and time.
