问题标签 [redis-streams]

Kafka 流/redis 流是否适合反应式架构？我问这个主要是因为 redis 和 kafka 在使用消息时似乎都在阻塞线程。

这背后有什么原因吗？我希望我可以通过一些回调读取消息 - 所以当消息像发布/订阅一样以反应方式传递时执行。不是通过阻塞线程。

Redis 流是否受益于集群模式？想象一下，您有 10 个流，它们是分布在集群中还是都分布在同一个节点上？我计划使用 Redis 流来实现非常高的吞吐量（2m+ 消息/秒），所以我担心 Redis 流在这种规模下的性能。

如果没有在集群模式下开箱即用地扩展 Redis 流，那么任何水平扩展 Redis 流的指导都会很棒。

我是redis的新手，我想使用NestJs从redis流中读取。

我试过：

但我不知道如何在将新键值添加到流中时进行记录

我可以连接到这个 URL 并使用redis--cli -h my-redis-stream.com（XADD XINFO XLEN 等）阅读

一个具体的例子会很有帮助，但我在互联网上没有找到任何例子，而且我无法从文档中得到我想要的东西。

如何使用 redis cli 不断地从流中消费和输出消息？

我尝试了下面的命令，但是它只使用最后一条消息，但我想要从 redis cli 中不断消耗和输出消息，同时发布者不断发布消息。

XREAD BLOCK 0 STREAMS mystream $

我正在尝试使用 SuperSet 制作实时仪表板，我在 kafka 中获取事件，然后通过 Spark Streaming 流式传输和处理它，然后对于我的数据存储，我想使用 Redis Streams（来自 Redis，我将实时查询我的数据）我可以这样做吗？

我用来生成连接和读取消息的包是：“github.com/go-redis/redis”

当我从 golang 中的一个组中读取事件时，我试图声明不使用 NOACK，但是当一个新事件到达时，它会留下这个新事件，就好像它有 NOACK 一样。

在这一部分中，我声明了我如何阅读消息并声明我不使用 ack。

之后，我从 redis-cli 发送一条消息

我从我的 Golang 脚本中得到

如果消息仍在处理中但似乎丢失，则有效。

I am using redis stream with node js, I am facing issue when returning the async callback value. please give me suggestion on how I can return value below is my code

我正在尝试从 Redis 流中读取数据，这一行给了我这个错误：

错误：“ReplyError：“xrevrange”命令的参数数量错误“

我需要有关此错误的帮助，或者如果有其他方法可以从 Redis 流中读取数据，请告诉我。

我正在寻找关于我们如何实现短期队列（主题）来执行 ETL 的建议，在 ETL 完成后，队列（主题）和数据不再需要。

这是场景..在运行特定作业的情况下，它必须运行查询以从数据库中提取数据（假设是 teradata）并将其加载到主题中。然后将启动一个 spark 作业，它将处理该主题中的所有记录并停止 spark 作业。之后不再需要该主题和数据。

为此，我将 Kafka 和 Redis 流视为 2 个选项，在我看来 Redis steam 是最合适的工具，因为它易于创建主题和销毁。对于 Kafka，我发现它需要额外的自定义处理程序来创建主题和删除主题等，也不想利用太多主题来利用 Kafka。

如果我们有另一个替代和更好的解决方案，我很高兴收到您的来信。

我需要多个 Redis Stream 来传递消息，这些消息具有相似的格式。所以我定义了一个泛型类：

然后我向 redis 流添加一条消息，如下所示：

我从 Redis 得到这样的记录：

似乎该值被忽略了。

如何正确使用 RedisTemplate 将通用对象添加到 Redis Stream？