寫了一個工具,從kafka傳輸數據到hdfs,採用的api,能夠消費指定的kafka topicgit
或者爲了簡即可以消費全部的topic中各個partition的數據。github
地址:https://github.com/voyage1314/kafka-hadoop-consumerapi