-record(delta, {
    processed_records :: integer(),
    lag_ms :: integer(),
    retry_count :: integer(),
    dead_letter_count :: integer(),
    elapsed_ms :: integer()
}).