kafka_2.12-2.4.x-consumer消费者-java原生api实现
kafka_2.12-2.4.x-topic主题、分区操作-java原生api实现
flink1.12.x WaterMark 迟到数据丢失和收集OutputTag
flink1.12.x Watermark 迟到数据 allowedLateness()
flink1.12.x sink-FileSink写入到文件，自定义桶名（文件夹名）
flink1.12.x FlinkCEP-打印watermark，理解处理连续三次登录失败
flink1.12.x Table API 和 SQL：Connector 连接器从kafka读取数据
flink1.12.x Process Function-KeyedProcessFunction函数-订单超时取消案例（处理时间）
flink1.12.x 窗口函数（window function）-增量 AggregateFunction 结合 全量 ProcessWindowFunction
flink1.12.x 实现wordcount-上传到flink集群，flink run执行jar-连接socket（TCP）服务器