flume采集下沉到kafka再上传到hdfs整体思路:
整体思路: 写一个循环脚本制造假数据,通过flume将这些数据下沉到kafka中,然后通过java代码,把这些数据暂存到本地临时路径下,然后设置一个定时器,定时将这些数据上传到hdfs中,代码如下:1、消费者:负责将数据放到本地路径暂存import java.io.File;import java.io.FileNotFoundException;import ja...