Function load_replay_id 

pub async fn load_replay_id(
    store: &PgStore,
    stream_name: &str,
) -> Result<Option<ReplayId>, ForceSyncError>

Loads the stored replay cursor for a CDC stream.

Errors

Returns an error if the checkpoint cannot be loaded or decoded.