apache-flink - Flink Redis 接收流

Question

我有一个用例，我想在 Flink 中对 DataStream 执行某些操作并将生成的聚合添加到 Redis。我想将数据放入Flink 的Redis Streams数据结构中。现在根据我的研究，我发现 Flink 中已经有一个 Redis sink 连接器可以使用。但此连接器中可用的数据类型只有：HASH、LIST、SET、PUBSUB、STRING、HYPER_LOG_LOG、SORTED_SET

参考：https://www.javadoc.io/static/org.apache.flink/flink-connector-redis_2.11/1.1.4/org/apache/flink/streaming/connectors/redis/common/mapper/RedisDataType。 html

是否可以从 Flink 将数据放入 Redis 流？我们可以为此编写自定义实现吗？是否有人尝试过类似的方法并在可能的情况下提供参考？

在这方面的任何线索将不胜感激。

标签： apache-flinkflink-streaming