【问题标题】:How to get the lag size of a consumer group in redis stream?如何在redis流中获取消费者组的滞后大小?
【发布时间】:2018-11-09 00:53:05
【问题描述】:

假设我有流mystream,和一个群组mygroup,我如何获得未消费消息的长度?

【问题讨论】:

  • 你看过XPENDING这个命令吗?
  • @ItamarHaber 是的,但这是待处理的大小而不是滞后大小
  • 所以也许我没有跟上,为我的缓慢道歉 - 请解释长度和滞后大小。
  • @ItamarHaber Lag size 是没有消费者处理过的消息的大小
  • 添加了答案。读取“滞后”的用例是什么?

标签: redis


【解决方案1】:

不,没有办法做到这一点。

可以分别使用XINFO GROUPS and XINFO STREAM 命令获取组和流中传递的最后一条消息 ID。

但是,没有返回流子范围长度的命令。如果存在这样的命令,可能需要线性时间复杂度,在这种情况下,它可能不会被实现。

【讨论】:

  • 我认为这将是一些元信息,redis 可以在新消息发布和使用时更新。相信kafka里面有这样的功能
猜你喜欢
  • 2019-09-27
  • 2019-01-13
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 2016-12-06
  • 2021-04-18
相关资源
最近更新 更多