flink1.12.x 重分区算子-shuffle()、rescale()
kafka_2.12-2.4.x-producer生产者-java原生api实现
flink1.12.x Rich Function富函数
flink1.12.x Transformation-reduce自定义聚合
flink1.12.x StreamExecutionEnvironment获取执行环境
flink1.12.x 实现wordcount-上传到flink集群，flink run执行jar-连接socket（TCP）服务器
flink1.12.x DataStream实现wordcount- 连接socket（TCP）服务器-lambda写法
flink1.12.x DataStream实现wordcount- 连接socket（TCP）服务器-java写法
kafka_2.12-2.4.x-consumer_offsets文件
kafka_2.12-2.4.x-consumer消费者命令 和 producer生产者命令（linux）