Packages

franz

3.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@consumer@topic_subscriber_Builder.hrl
Raw

include/franz@consumer@topic_subscriber_Builder.hrl 

-record(builder, {

    name :: gleam@erlang@process:name(franz@consumer@topic_subscriber:message()),

    client :: franz:client(),

    topic :: binary(),

    partitions :: franz@consumer@topic_subscriber:partitions(),

    commited_offsets :: list({integer(), integer()}),

    message_type :: franz@consumer@message_type:message_type(),

    callback :: fun((integer(), franz:kafka_message(), any()) -> franz@consumer@topic_subscriber:ack()),

    init_callback_state :: any(),

    consumer_config :: list(franz@consumer@config:config())

}).