完整流程
完整流程
XGROUP CREATE orders g1 0 MKSTREAM # 建组，从 0 起（含历史）
XREADGROUP GROUP g1 consumer1 COUNT 10 BLOCK 2000 STREAMS orders >
XACK orders g1 1737100000000-0 # 处理完成确认
XPENDING orders g1 # PEL 概览（数量/最小最大ID/消费者）
XPENDING orders g1 - + 10 # 明细（含投递次数/空闲时间）
XAUTOCLAIM orders g1 consumer2 60000 0-0 COUNT 10 # 认领空闲>60s 的消息
XINFO GROUPS orders
XINFO CONSUMERS orders g1| > 与 ID | > 只投递从未投递的新消息；指定 ID 则读自己 PEL 里的历史 |
|---|---|
| ACK 语义 | 确认后才从未处理列表移除；不 ACK 会重复投递 |
| 故障转移 | XAUTOCLAIM 按空闲时间批量认领，替代逐个 XCLAIM |
PEL 只增不减通常有两个原因：消费者没 XACK；或消费者宕机后没人认领。要监控 XPENDING 数量。