franz/group_subscriber

Types

CallbackReturn

pub type CallbackReturn

GroupBuilder

opaque </>

pub opaque type GroupBuilder(callback_init_state)

Values

ack

</>

pub fn ack(cb_state: cb_state) -> CallbackReturn

Acknowledge the processing of the message.

commit

</>

pub fn commit(cb_state: cb_state) -> CallbackReturn

Commit the offset of the last message that was successfully processed.

new

</>

pub fn new(
  client client: franz.FranzClient,
  group_id group_id: String,
  topics topics: List(String),
  message_type message_type: message_type.MessageType,
  callback callback: fn(franz.KafkaMessage, callback_init_state) -> CallbackReturn,
  init_callback_state init_callback_state: callback_init_state,
) -> GroupBuilder(callback_init_state)

Create a new group subscriber builder.

start

</>

pub fn start(
  group_builder: GroupBuilder(callback_init_state),
) -> Result(process.Pid, franz.FranzError)

Start a new group subscriber.

stop

</>

pub fn stop(pid: process.Pid) -> Result(Nil, franz.FranzError)

with_consumer_config

</>

pub fn with_consumer_config(
  group_builder: GroupBuilder(callback_init_state),
  consumer_config: consumer_config.ConsumerConfig,
) -> GroupBuilder(callback_init_state)

Add a consumer configuration to the group builder.

with_group_config

</>

pub fn with_group_config(
  group_builder: GroupBuilder(callback_init_state),
  group_config: group_config.GroupConfig,
) -> GroupBuilder(callback_init_state)

Add a group configuration to the group builder.