写了一个工具,从kafka传输数据到hdfs,采用的api,能够消费指定的kafka topicgit
或者为了简即可以消费全部的topic中各个partition的数据。github
地址:https://github.com/voyage1314/kafka-hadoop-consumerapi