Redis Sink 自定义

文章目录 背景 依赖 SinkFunction & RichSinkFunction Demo 参考 背景 Flink 默认的 RedisMapper 不能设置key的过期时间。 依赖 <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.9.0</ve

>>阅读原文<<