kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sam William <sa...@stumbleupon.com>
Subject Kafka Sample Hadoop consumer.
Date Tue, 09 Aug 2011 22:32:16 GMT
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