Flink kafka簡單示例（一）統計topic中的單詞後寫入新的topic

最近在調研各種計算框架，在看完Kafka Stream之後也順便看了一下最流行的Flink，結合我們業務場景試驗了一些小demo。下面給出一個簡單示例，基本和官方類似。只是使用了最新的版本Flink kafka connector以及最新版本的Flink 1.7.2（截止2019年2月） 示例簡要介紹 第一步將kafka topic作爲source添加到DataStream 第二步讀取topic的

>>阅读原文<<