加入Redis streams

Question

我对Redis streams非常感兴趣。(看起来有可能构建由append-log驱动的小型系统，如Kafka，但没有Kafka的所有开销。)

它看起来很简单，可以通过XADD访问日志/流，并使用日志/流中的条目。但是如果你想跨两个流加入呢？

Kafka Streams、Flink、Spark等提供了这样做的方法。在Redis宇宙中有没有等价物？

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

Answer 1

如果我是正确的，你正在寻找一种方法来加入两个Redis流。

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

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