Flink快速入门

本文会实现一个简单的基于Flink的流处理应用，从Kafka中读取流数据，统计单词出现的个数，然后输出到Redis里。

安装Flink

切换路径到 ：

访问http://localhost:8081：

安装Zookeeper和Kafka

启动Zookeeper：

启动Kafka：

创建一个Topic： ：

安装Redis

编写代码

当然也可以在IDEA里增加一个 ：

:

:

打Jar包：

上传到Flink集群上执行：

这时候去之前Kafka的Producer输入单词：

去Redis查看：