pub async fn run(
    commit_log: FileLog,
    keys_expected: usize,
    offset_store_id: OffsetStoreId,
    offset_store_receiver: Receiver<Command>
) -> Result<()>
Expand description

Runs an offset store.