Function run_once 

pub async fn run_once(
    params: &CheckpointParams,
    store: &OffsetSyncStore,
) -> Result<(), ReplicatorError>

One translation pass: reads source group offsets, translates them with store, and writes Checkpoint records to the target checkpoints topic.

Errors

Returns ReplicatorError on topic-ensure, admin-connect, or produce failures.