Redis Streams 交互回放

选择场景，逐步观察 Stream、Consumer Group、PEL、XACK 与 XCLAIM 接管。

场景

Docker 证据已验证redis:8.2.1@sha256:5fa2e

速度 0.5×1×2×1 / 32

Producerdone

→

Streamidle

→

Consumer Groupidle

→

Consumeridle

→

业务数据库idle

当前事件

Broker 已确认发布 +0 ms

messageId

01JMQ000000000000000000001

location

broker

queue

orders.basic

status

confirmed

业务状态

原始证据

demos/redis-streams/basic/producer.out.txt:1producer

[producer] timestamp=2026-10-07T10:33:50.433220957Z level=INFO service=order-service product=redis-streams lab=basic messageId=01JMQ000000000000000000001 eventType=order.created schemaVersion=1 aggregateId=order-1001 traceId=00000000000000000000000000000001 correlationId=order-1001 destination=orders.basic entryId=1791369230432-0 durationMs=18 status=confirmed

最终断言

PASS confirmed: 3
PASS received: 3
PASS uniqueMessageIds: 3
PASS redeliveredCount: 0
PASS businessCommitted: 3
PASS duplicatesSkipped: 0
PASS business_rows: 3
PASS streamLengthAfter: 3
PASS pendingAfter: 0
PASS consumer.exitCode: 0
RESULT: all assertions passed