-record(observation, {
    profile :: binary(),
    lag_ms :: integer(),
    throughput_records_per_sec :: integer(),
    retry_count :: integer(),
    processed_records :: integer(),
    replay_recovery_ms :: integer()
}).