Turns out that I forgot to change my POM to use 2.10 version, this fixes it in case someone else is trying to do the same thing <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.10</artifactId> <version>0.8.0</version> </dependency>
Bob On 10/31/13, 10:53 AM, "Ngu, Bob" <bob....@intel.com> wrote: >I built and deployed latest 0.8 version on Scala 2.10.2 to my local maven >repository. I also started a sample producer API app using Scala 2.10.2, >building the app causes java.lang.NoClassDefFoundError error when calling >ProducerConfig, see below for code. > >package com.foo.bar >package common > >import kafka.javaapi.producer.Producer >import kafka.producer.KeyedMessage >import kafka.producer.ProducerConfig > >import java.util.Properties > >class KafkaProducer { > // create a producer > > val props = new Properties() > > props.put("metadata.broker.list", "broker0:9092") > props.put("serializer.class", "kafka.serializer.StringEncoder") > props.put("request.required.acks", "1") > > val config = new ProducerConfig(props) > > val producer = new Producer[String, String](config) > > //sending... > val topic = "test" > val message = "_Message_1" > val keyedMessage = new KeyedMessage[String, String](topic, message) > producer.send(keyedMessage) > >} > >Any help is much appreciated. > >Thanks, >Bob