Another kafka-hadoop-consumer
Java
Latest commit e27b2f5 Apr 17, 2013 @miniway Merge pull request #2 from cresny/master
Fix to support batched/compressed messages

README.md

kafka-hadoop-consumer

Another kafka-hadoop-consumer

Quick Start

$ mvn start
$ java -cp target/hadoop_consumer-1.0-SNAPSHOT.jar:`hadoop classpath` kafka.consumer.HadoopConsumer -z <zookeeper> -t <topic> target_hdfs_path