40歲程序員學Flink,對接kafka

一,背景 公司需要用到flink和kafka來處理大數據,對於一個沒有接觸過這兩個東西的40歲程序員,決定自學一下,用了兩天的時間終於實現了flink和kafka的對接,目標就是要向kafka輸入 "時間戳,溫度,設備ID",然後在flink裏面按照時間戳分組,再按照設備ID計算的在一個時間段內的溫度平均值。   二,運行環境 window 10, kafka 2.1.1, flink 1.7.2
相關文章
相關標籤/搜索