Current section
Files
Jump to
Current section
Files
include/franz@group_subscriber_GroupBuilder.hrl
-record(group_builder, {
client :: franz:client(),
group_id :: binary(),
topics :: list(binary()),
message_type :: franz@message_type:message_type(),
callback :: fun((franz:kafka_message(), any()) -> franz@group_subscriber:callback_return()),
init_callback_state :: any(),
group_config :: list(franz@group_config:group_config()),
consumer_config :: list(franz@consumer_config:consumer_config())
}).