kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Neha Narkhede <neha.narkh...@gmail.com>
Subject Re: Kafka Sample Hadoop consumer.
Date Tue, 09 Aug 2011 23:29:47 GMT
Sam,

I tried this on a downloaded copy of kafka
v0.6<http://sna-projects.com/kafka/downloads/kafka-0.6.zip>-

nnarkhed-md:kafka nnarkhed$ jar tvf kafka-0.6.jar | grep
"kafka.javaapi.consumer.SimpleConsumer"
  3501 Tue May 24 10:23:24 PDT 2011
kafka/javaapi/consumer/SimpleConsumer.class

I suspect that the kafka-0.6.jar is not registered correctly with the
DistributedCache.

Thanks,
Neha

On Tue, Aug 9, 2011 at 3:32 PM, Sam William <sampd@stumbleupon.com> wrote:

> Im trying to run this  sample hadoop consumer in the 0.6 version .   I see
> that the jar files (including kafka-0.6.jar) are proper when being copied to
> the DistributedCache , but I get the exception
>
> Error: java.lang.ClassNotFoundException:
> kafka.javaapi.consumer.SimpleConsumer
>        at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
>        at java.security.AccessController.doPrivileged(Native Method)
>        at java.net.URLClassLoader.findClass(URLClassLoader.java:190)
>        at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
>        at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
>        at java.lang.ClassLoader.loadClass(ClassLoader.java:248)
>        at kafka.etl.KafkaETLContext.(KafkaETLContext.java:93)
>        at
> kafka.etl.KafkaETLRecordReader.next(KafkaETLRecordReader.java:115)
>        at kafka.etl.KafkaETLRecordReader.next(KafkaETLRecordReader.java:14)
>        at
> org.apache.hadoop.mapred.MapTask$TrackedRecordReader.moveToNext(MapTask.java:192)
>        at
> org.apache.hadoop.mapred.MapTask$TrackedRecordReader.next(MapTask.java:176)
>        at org.apache.hadoop.mapred.MapRunner.run(MapRunner.java:48)
>        at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:358)
>        at org.apache.hadoop.mapred.MapTask.run(MapTask.java:307)
>        at org.apache.hadoop.mapred.Child.main(Child.java:170)
>
>
>
> Is there something Im missing here ?
>
>
> Sam William
> sampd@stumbleupon.com
>
>
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message