如何将kafka收到的消息写入到HDFS中进行统计分析？

kakfa生产者生成一些列的文件，文件中包括各种类型的日志文件。 生产者将文件发送到kafka， 请问下 kakfa接收到生产者的日志文件后，如何将文件发送到HDFS上。HDFS同时需要根据日志类型分类存储，最后hive做离线统计分析。