-record(snapshot, {
    lag_ms :: integer(),
    throughput_records_per_sec :: integer(),
    retry_count :: integer(),
    dead_letter_count :: integer()
}).