本文开头附：Flink 学习路线系列 ^ _ ^

        本文主要来介绍 Flink 读取 Kafka数据，并实时下沉(Sink)数据到 Redis 的过程。

       通过如下链接：Flink官方文档，我们知道数据保存到 Redis 的容错机制是 at least once。所以我们通过幂等操作，使用新数据覆盖旧数据的方式，以此来实现 exactly-once 。

1.代码部分

1.1 config.properties配置文件

bootstrap.server=192.168.204.210:9092,192.168