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

Reply via email to