You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by "Ngu, Bob" <bo...@intel.com> on 2013/10/31 18:53:10 UTC

java.lang.NoClassDefFoundError: scala/reflect/ClassManifest

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

Re: java.lang.NoClassDefFoundError: scala/reflect/ClassManifest

Posted by "Ngu, Bob" <bo...@intel.com>.

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" <bo...@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