Redis XPENDING 怎么查看消费组中最老的未确认消息

Redis Stream 使用消费组读取消息时，消息被某个消费者读到但还没有执行 XACK，就会进入 Pending Entries List。要查看消费组中按消息 ID 最早的未确认消息，最直接的命令是：

XPENDING orders-stream order-workers - + 1
# orders-stream 是 Stream key，order-workers 是消费组
# - 和 + 表示从最小 ID 到最大 ID，1 表示只取一条

返回结果的第一项是消息 ID，第二项是当前消费者，第三项是距离上次投递经过的毫秒数，第四项是投递次数。这里的“最老”指 Pending 列表中消息 ID 最小，不等于空闲时间最长。后者要用 IDLE 条件单独查询。

Redis XPENDING 先看消费组的 Pending Entries List

XPENDING 只检查消费组的待确认记录，不读取 Stream 的字段内容，也不会自动确认或转移消息。先执行摘要形式，适合判断问题规模：

XPENDING orders-stream order-workers
# 这个形式不带范围参数，只返回消费组摘要

摘要通常包含四部分：pending 总数、最小消息 ID、最大消息 ID，以及每个拥有 pending 消息的消费者和对应数量。例如返回的结构可以理解为：

如果第一项为 0，后面的最小和最大 ID通常为空，此时没有可供 XPENDING ... - + 1 查询的 pending 消息。不要用 Stream 中最早的消息 ID代替 pending 最小 ID，两者属于不同集合。

用扩展查询确认按 ID 最早的未确认消息

要拿到摘要中的最小 ID对应的完整 pending 元数据，可以把范围设为整个 ID空间、数量设为 1：

XPENDING orders-stream order-workers - + 1
# 结果按 Pending Entries List 的 ID 顺序返回，数量限制为 1

扩展形式每条记录有四个字段：消息 ID、当前 owner、idle 毫秒数、投递次数。假设结果类似 1728000000000-0 worker-a 42000 2，可读成“消息 ID 为 1728000000000-0，由 worker-a 持有，距上次投递约 42 秒，累计投递 2 次”。这一步已经能回答“最老的是谁、当前被谁拿着、多久没动过”。

如果需要查看这条消息的业务字段，再用同一个 ID查询 Stream：

XRANGE orders-stream 1728000000000-0 1728000000000-0
# 只回查这个 ID，避免把整条 Stream 扫出来

用 consumer 和 IDLE 条件缩小排查范围

当摘要显示多个消费者都有 pending 消息时，可以追加消费者名称，只查看该 owner 的记录：

XPENDING orders-stream order-workers - + 20 worker-a
# 只查询 worker-a 持有的 pending 消息，最多返回 20 条

Redis 6.2及以上还支持 IDLE，单位是毫秒。下面的命令只找空闲至少 60 秒的 pending 消息：

XPENDING orders-stream order-workers IDLE 60000 - + 20
# IDLE 过滤的是距上次投递的空闲时长，不是消息 ID年龄

因此可以这样区分两个目标：

查询结果中的 idle 较大、deliveries 不断增加，通常说明消费者重复读取或处理失败；idle 较小但 pending 数量持续上升，则更像消费速度跟不上生产速度。这里是排查线索，不应只凭一条命令直接判定业务故障。

查到最老消息后不要误用 XACK 或转移命令

XPENDING 是只读观察命令。确认业务已经成功处理后，才对明确的消息 ID执行 XACK；如果原消费者失效且消息已超过恢复阈值，再根据幂等策略评估 XAUTOCLAIM 或 XCLAIM。直接对“最小 ID”执行确认，可能把尚未处理的订单、支付或库存事件从待确认列表移除。

生产排查可以按这份清单走：先记下 pending 总数和最小 ID，再取一条扩展明细；随后用 XRANGE 核对业务字段，查看 owner、idle 和 deliveries；最后结合消费者日志决定修复、确认或恢复。命令本身耗时与返回条数有关，日常观察应使用较小的 count，不要无条件拉取整个 Pending 列表。

常见问题

XPENDING 返回空结果怎么办？

先确认 Stream key和消费组名称没有写错，再执行摘要形式。如果 pending 总数为 0，说明当前没有未确认记录；如果命令报错，则检查消费组是否已经创建。

最小 pending ID能直接拿到消息内容吗？

不能。XPENDING 返回的是 Pending Entries List 元数据，要用 XRANGE stream id id按这个 ID回查 Stream 字段。

怎么找空闲最久的消息？

XPENDING 的扩展结果包含 idle 毫秒数，可使用 IDLE筛出超过阈值的记录，再结合返回的 idle 值和消费者状态判断。按 ID最小并不代表空闲最久。

Redis 官方命令说明可参考 XPENDING 文档，其中还列出了范围、消费者过滤和 IDLE参数的完整语法。