Scala Flink1.7 消費kafka2.x模板 數據存入hdfs

demo1將數據從kafka之中讀取出來，wordwount最後將寫出的數據存入hdfs demo2 將數據存入Dgraph 圖數據庫 （全爲Scala實現） kafka、flink等相關依賴與 maven打包依賴 <dependencies> <dependency> <groupId>org.apache.beam</groupId>

>>阅读原文<<