-record(freshness_metadata, {
    max_allowed_lag_ms :: integer(),
    observed_lag_ms :: integer(),
    last_sequence :: integer(),
    is_fresh :: boolean()
}).