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