Redis 流分区

Question

我正在尝试了解 redis 流如何进行分区，如果特定的消息可以发送到特定的分区(类似于您对 Kafka 的处理方式)。

我检查了 redis-cli api，没有类似于分区的东西，在使用 StackExchangeRedis redis 库时也没有。

唯一的方法是:IDatabase.StreamAdd(key,streamKey,streamValue,messageId)

我错过了什么吗？分区是否仅以固定方式完成？

P.S 如果可以分区，是否可以组成分区键？

Answer 1

您无法使用单个 Redis Stream 实现 Kafka 分区。 Redis Stream 的消费者组看起来像一个负载均衡器，它将流中的消息分发给不同的消费者，没有任何分区。如果一个消费者比其他消费者更快，那么无论消息的逻辑分区如何，它都会比其他消费者消费更多的消息。

如果要做partition，就得用多个Redis Streams，也就是多个key，每个key对应不同的partition。您的生产者将逻辑分区中的消息添加到专用的 Redis 流中。不同的消费者从不同的 key 读取消息。