On Oct 29, 2014, at 3:03 PM, Jack Foy <j...@whitepages.com> wrote: > On Oct 29, 2014, at 1:46 PM, Neha Narkhede <neha.narkh...@gmail.com> wrote: >> Which version of Scala did you use for Kafka 0.8.2-beta? > > The problem reproduces under both Scala 2.10.4 and Scala 2.11.2.
Sorry, to be clearer: I am using SBT with the following dependency line, to pull in the specific package for the version of Scala I’m running. libraryDependencies ++= Seq( "org.apache.kafka" %% "kafka" % "0.8.2-beta" exclude("javax.jms", "jms") exclude("com.sun.jdmk", "jmxtools") exclude("com.sun.jmx", "jmxri") exclude("log4j", "log4j") ) I tried the following combinations: Scala 2.10.4, kafka 0.8.1.1, my old code - compiled Scala 2.10.4, kafka 0.8.2, my old code - failed Scala 2.11.2, kafka 0.8.2, my old code - failed Scala 2.10.4, kafka 0.8.2, my new code - compiled Scala 2.11.2, kafka 0.8.2, my new code - compiled -- Jack Foy <j...@whitepages.com>