-record(builder, {
    client :: franz:franz_client(),
    topic :: binary(),
    partitions :: franz@partitions:partitions(),
    commited_offsets :: list({integer(), integer()}),
    message_type :: franz@message_type:message_type(),
    callback :: fun((integer(), franz:kafka_message(), any()) -> franz@topic_subscriber:ack()),
    init_callback_state :: any(),
    consumer_config :: list(franz@consumer_config:consumer_config())
}).