Kafka 交互回放

选择场景，逐步观察 Partition、Consumer Group、offset、lag、回放与事务可见性。

场景

Docker 证据已验证apache/kafka:4.3.1@sha256:77e3d

速度 0.5×1×2×1 / 33

Produceridle

→

Topicidle

→

Partitionidle

→

Consumeridle

→

业务数据库idle

当前事件

produced +0 ms

messageId

01JMQ000000000000000000001

queue

orders.basic

partition

0

offset

0

status

produced

业务状态

原始证据

demos/kafka/basic/producer.out.txt:4producer

[producer] timestamp=2026-10-07T10:29:45.278255208Z level=INFO service=order-service product=kafka lab=basic messageId=01JMQ000000000000000000001 eventType=order.created schemaVersion=1 aggregateId=order-1001 traceId=00000000000000000000000000000001 correlationId=order-1001 destination=orders.basic partitionOrQueue=0 offset=0 seq=1 durationMs=261 status=produced

最终断言

PASS produced: 3
PASS received: 3
PASS uniqueMessageIds: 3
PASS businessCommitted: 3
PASS business_rows: 3
PASS consumerGroupLag: 0
PASS consumer.exitCode: 0
RESULT: all assertions passed