Flink kafka简单示例（一）统计topic中的单词后写入新的topic

最近在调研各种计算框架，在看完Kafka Stream之后也顺便看了一下最流行的Flink，结合我们业务场景试验了一些小demo。下面给出一个简单示例，基本和官方类似。只是使用了最新的版本Flink kafka connector以及最新版本的Flink 1.7.2（截止2019年2月） 示例简要介绍 第一步将kafka topic作为source添加到DataStream 第二步读取topic的

>>阅读原文<<