Redis Sink 自定義

文章目錄 背景 依賴 SinkFunction & RichSinkFunction Demo 參考 背景 Flink 默認的 RedisMapper 不能設置key的過期時間。 依賴 <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.9.0</ve

>>阅读原文<<