flink读取kafka数据未能触发watermark 过年被病毒闹的出不了门，就顺带着把flink秒级统计的逻辑写了一下，逻辑很简单，就是从kafka消费数据，然后select count(*) from xxx group by xxx来一秒产出一个打点。程序代码非常简单 继续阅读“flink读取kafka数据未能触发watermark”