Redis Streams 已有流创建消费者组的起始 ID 配置方法
给已有 Redis Stream 建消费者组时，最关键的不是组名，而是 XGROUP CREATE 后面的起始 ID：用 0-0 回放已有消息，用 $ 从当前末尾开始只接收后续消息；Stream 还不存在时再加 MKSTREAM。这个选择只发生在建组时，不能拿读取命令里的 > 代替。
官方地址：https://redis.io/docs/latest/
先分清四个位置概念
Stream 是消息日志，消费者组保存一份组级消费进度，消费者名称用于标识组内的工作实例。0-0 和 $ 是创建组时的初始化起点；消费者调用 XREADGROUP 时，> 表示取从未投递给组内其他消费者的新消息，普通 ID 则表示读取当前消费者自己的历史 Pending 项。
因此，首次建组要回答的是“这批旧消息要不要进入这个组”，而不是“某个消费者下一次从哪里读”。
已有 Stream：回放历史还是只收新消息
需要补偿、重建索引或首次迁移时，通常从 0-0 开始；实时通知、旁路统计或新版本 worker 上线时，通常选择 $，避免把很久以前的消息一次性灌入新组。
# 从已有 Stream 的第一条消息开始，让新组具备历史回放能力
redis-cli XGROUP CREATE orders order-workers 0-0
# 只从创建组之后产生的消息开始消费，忽略已有历史
redis-cli XGROUP CREATE orders order-workers $
这里的 orders 是 Stream key，order-workers 是消费者组。创建成功后，worker 再用同一个组名和唯一消费者名调用 XREADGROUP ... >。如果业务需要固定的历史截止点，不要用模糊的时间判断替代 Stream ID，应先记录明确的消息 ID，再设计回放边界。
Stream 不存在时使用 MKSTREAM
MKSTREAM 只负责在 key 不存在时创建一个空 Stream，不会制造一条业务消息。它适合部署初始化、生产者和消费者启动顺序不固定的场景；如果 Stream 已经存在，该参数不会改变已有数据和起始策略。
# key 不存在时创建空 Stream，再建立从末尾开始的消费者组
redis-cli XGROUP CREATE orders order-workers $ MKSTREAM
若你要求首次上线必须消费历史数据，就把 $ 换成 0-0。不要因为加了 MKSTREAM 就误以为组会自动补读历史，真正决定起点的仍是前一个 ID 参数。
把重复执行设计成幂等流程
部署脚本可能被重试。组已经存在时，Redis 会返回 BUSYGROUP Consumer Group name already exists 一类错误，这通常说明初始化已完成，不应该每次启动都删除组重建。删除重建会丢失组进度，尤其不适合生产环境。
推荐把“组不存在”视为需要创建，把“组已存在”视为继续启动；其他权限、连接或参数错误再中止。起始 ID 一旦被首次创建确定，后续重试不会把它改成另一个值。
用 XINFO 和一次读取确认结果
# 查看组的 last-delivered-id、消费者数量和待处理数量
redis-cli XINFO GROUPS orders
# 使用组内唯一消费者读取新消息；COUNT 只限制本次返回数量
redis-cli XREADGROUP GROUP order-workers worker-01 COUNT 10 STREAMS orders >
从头创建的组，初始化后应能看到已有消息可被组内消费者读取；从 $ 创建的组，在没有新写入时可能暂时没有返回，这是预期现象。XINFO GROUPS 看到的 last-delivered-id 反映组进度，不等同于 Pending 列表的恢复动作。确认消息仍要在业务处理成功后调用 XACK，不要用初始化参数代替确认。
生产配置检查清单
| 场景 | 创建方式 | 主要风险 |
|---|---|---|
| 历史补偿或迁移 | 0-0 | 历史量大时首次消费压力高 |
| 实时旁路消费 | $ | 旧消息不会自动补偿 |
| key 可能不存在 | 加 MKSTREAM | 只创建空流，不产生业务消息 |
| 部署脚本重试 | 捕获 BUSYGROUP | 不要删除组来“修复”重复创建 |
最后再检查三件事：起始 ID 是否符合业务数据边界、消费者名称是否按实例唯一、组已存在时是否保留原进度。把这三项写进部署配置和启动日志，后续排查就能快速区分“组没建好”“没有新消息”和“消息在 Pending 中”这三类完全不同的情况。
常见问题
创建组后为什么读不到旧消息？如果用的是 $，旧消息被有意排除；要回放历史，需要新建一个组并以 0-0 初始化，或制定单独的补偿流程。
可以用 XREADGROUP 的 0-0 修改组起点吗？不能。它只读取当前消费者的历史 Pending 项，不会重置组的初始化位置。
MKSTREAM 会不会覆盖已有 Stream？不会。它只在 key 不存在时创建空 Stream，已有 key 的消息和组状态不会被它重置。
