Versions Compared

Old Version 31

changes.mady.by.user Federico Valeri

Saved on

compared with

New Version 32

changes.mady.by.user Federico Valeri

Saved on

Key

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

...

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).

When ProducerStateManager encounters a MIRROR_PID_RESET batch during normal append or during recovery (LogSegment.recover replays all batches):                                                                                                                                                          

...