-record(kafka_message_set, {
    topic :: binary(),
    partition :: integer(),
    high_wm_offset :: integer(),
    messages :: list(franz:kafka_message())
}).