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