Module offset_sync_store 

In-memory source->target offset translation built from MM2 offset-sync records. Translation is “at-or-before”: find the latest sync with upstream <= committed, then downstream + (committed - upstream). Never maps past un-replicated data.

Structs

OffsetSyncStore

Accumulates OffsetSync records and translates committed source offsets to their corresponding target offsets.