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 <sa...@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 > sa...@stumbleupon.com > > > >
