Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Plain View
Kafka >> mail # user >> Re: NoClassDefFoundError exception when trying to instantiate a ProducerConfig


Copy link to this message
-
Re: NoClassDefFoundError exception when trying to instantiate a ProducerConfig
You should only include the 2.8 scala jar.

Thanks,

Jun
On Fri, Apr 5, 2013 at 9:41 AM, Withers, Robert <[EMAIL PROTECTED]>wrote:

> Hi,
>
> I have an Eclipse java project, with the 2.9.1 scala jar
> (scala-library-2.9.1.RC4.jar) in the build path, as well as the
> kafka_2.8.0-0.8-SNAPSHOT.jar.  I wrote the simple Producer example and try
> to run it and it fails with a NoClassDefFoundError runtime exception.  Here
> is my code and the error.   Thanks for any help!
>
> package com.sample;
>
> import java.util.Properties;
>
> import kafka.javaapi.producer.Producer;
> import kafka.producer.KeyedMessage;
> import kafka.producer.ProducerConfig;
>
> public class TestKafkaProducer {
>        public static void main(String[] args) {
>               Properties props = new Properties();
>               props.put("zk.connect", "127.0.0.1:2181");
>               props.put("serializer.class",
> "kafka.serializer.StringEncoder");
>               props.put("partitioner.class",
> "example.producer.SimplePartitioner");
>               props.put("request.required.acks", "1");
>               ProducerConfig config = new ProducerConfig(props);
>               Producer<String, String> producer = new Producer<String,
> String>(config);
>
>               KeyedMessage<String, String> data = new KeyedMessage<String,
> String>("page_visits", "kafka", "hello world");
>               producer.send(data);
>        }
> }
>
>
> And the error:
> Exception in thread "main" java.lang.NoClassDefFoundError:
> scala/Tuple2$mcLL$sp
>        at kafka.producer.ProducerConfig.<init>(ProducerConfig.scala:56)
>        at com.sample.TestKafkaProducer.main(TestKafkaProducer.java:16)
> Caused by: java.lang.ClassNotFoundException: scala.Tuple2$mcLL$sp
>        at java.net.URLClassLoader$1.run(Unknown Source)
>        at java.net.URLClassLoader$1.run(Unknown Source)
>        at java.security.AccessController.doPrivileged(Native Method)
>        at java.net.URLClassLoader.findClass(Unknown Source)
>        at java.lang.ClassLoader.loadClass(Unknown Source)
>        at sun.misc.Launcher$AppClassLoader.loadClass(Unknown Source)
>        at java.lang.ClassLoader.loadClass(Unknown Source)
>        ... 2 more
>
>
> Thanks,
> Rob
>

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB