scala編寫， flink 讀取kafka而且自定義水印再將數據寫入kafka中

flink 讀取kafka數據並指定event time做爲時間劃分 再將數據導入kafka中（每分鐘數據總和）（使用scala編寫-複製運行能夠直接跑通） 1.需求說明（自定義窗口，每分鐘的詞頻統計） 1.從kafka中讀取數據（topic：t1）。html 2.kafka中有event time時間值，經過該時間戳來進行時間劃分，窗口長度爲1分鐘，窗口步長爲1分鐘。java 3.因爲生產中可能

>>阅读原文<<