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
[email protected]
