Function run_once_with_policy 

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

Run one checkpoint pass with the deployment’s client resource policy.

Errors

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