-record(kafka_message, {
    offset :: integer(),
    key :: bitstring(),
    value :: bitstring(),
    timestamp_type :: franz:time_stamp_type(),
    timestamp :: integer(),
    headers :: list({binary(), binary()})
}).