scala编写， flink 读取kafka而且自定义水印再将数据写入kafka中

flink 读取kafka数据并指定event time做为时间划分 再将数据导入kafka中（每分钟数据总和）（使用scala编写-复制运行能够直接跑通） 1.需求说明（自定义窗口，每分钟的词频统计） 1.从kafka中读取数据（topic：t1）。html 2.kafka中有event time时间值，经过该时间戳来进行时间划分，窗口长度为1分钟，窗口步长为1分钟。java 3.因为生产中可能

>>阅读原文<<