Packages

franz

2.0.0
3.0.0 2.0.0 1.1.0 1.0.1 1.0.0 0.5.1 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0

A Gleam library for interacting with Kafka

HexDocs

Current section

Files

Jump to
Readme
11 Versions
4 Dependencies
Dependants
Files
Activity
franz include franz@topic_subscriber_Builder.hrl
Raw

include/franz@topic_subscriber_Builder.hrl 

-record(builder, {

    client :: 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())

}).