Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

A barrier control batch called MIRROR_PID_RESET is written to the destination partition's log during the PREPARING  -> MIRRORING  transition, after truncation completes but before the mirror fetcher starts appending data.

The original pid mapping logic is updated to skip it for positive PIDs, making it idempotent.

Barrier Schema

  • Batch header: producerId = -1, producerEpoch = -1, isControlBatch = true, isTransactional = false.
  • Key: Standard control record key (version=0, type=7) per existing ControlRecordType format.
  • Value (MirrorPidResetRecord): SourceClusterId, string, UUID of the source cluster; TimestampMs, int64, Wall-clock time when the barrier was written).

...