-record(batch, {
    key :: binary(),
    stage :: binary(),
    records :: integer(),
    lag_ms :: integer(),
    idempotency_key :: binary(),
    sequence :: integer()
}).