Get all consumer cursors for replay harness.

Get available replay checkpoints.

Returns significant sequence positions useful for replay testing.

Returns

List of checkpoint information including sequence and context

Get sequence range available for replay.

Get validation information for replay setup.

Replay events from a specific sequence position.

Simulates consumer reconnection and validates deterministic reconstruction.

Parameters

• from_sequence: Starting sequence (exclusive - events with sequence > from_sequence)
• to_sequence: Ending sequence (inclusive, optional)
• options: Replay configuration
  • validate_digests: Verify schema digests during replay (default true)
  • batch_size: Events per batch (default 100)
  • max_events: Maximum events to replay (default 1000)

  • consumer_mode: :simulation | :validation (default :validation)

Returns

%{ events_replayed: count, start_sequence: number, end_sequence: number,
duration_ms: milliseconds, validation_results: [...], errors: [...] }

Replay from a specific cursor position.

Test consumer behavior with simulated gaps and failures.

Validates consumer resilience under adverse conditions.

Parameters

• scenario: :gaps | :out_of_order | :duplicate | :schema_drift

• from_sequence: Starting sequence
• options: Test configuration

Returns

Test results with pass/fail status and detailed findings

Validate replay determinism between multiple runs.

Ensures that replaying the same sequence range produces identical results.

Parameters

• from_sequence: Starting sequence
• to_sequence: Ending sequence
• iterations: Number of replay runs (default 3)

Returns

Determinism validation results with consistency metrics