GitHub repository: Ksssssssss/flink
Primary language: Java
Description: 并发消费kafka数据并写入hdfs。 基于flink统计实时ip热点统计