加入Redis流

Question

我对 Redis 流非常感兴趣。（看起来有可能构建由附加日志驱动的小系统，比如 Kafka，但没有 Kafka 的所有开销。）

XADD对于日志/流和使用日志/流中的条目，它看起来很简单。但是如果你想跨两个流加入呢？

Kafka Streams、Flink、Spark 等提供了执行此操作的方法。Redis 宇宙中是否有等价物？

如果没有，我想我只需要实现我自己的东西，从两个流中消费，从消息中执行自己的连接逻辑，然后发布回新的流。如果其他人有使用 Redis Streams 执行此操作的经验，请分享您的指示或警告。

Answer 1

如果我是对的，您正在寻找一种连接两个 Redis 流的方法。

似乎有一个可用于 Spark 的连接器，它允许您使用流https://github.com/RedisLabs/spark-redis/blob/master/doc/streaming.md

从这里开始，用于连接的 Spark 逻辑应该很容易使用。