kafka写入hdfs
消费json格式kafka数据再以Parquet格式写入HDFS 每隔10000 ms进行启动一个检查点【设置checkpoint的周期】
下载地址
用户评论