off_broadway_kafka v1.0.1 OffBroadway.Kafka.ShowtimeHandler View Source

Defines an Elsa.Consumer.MessageHandler for integrating with Broadway which supports creating a pipeline per topic partition for increased concurrency.

Configuration for Kafka and Broadway are handled by the OffBroadway.Kafka.kafka_config/1 and OffBroadway.Kafka.broadway_config/3 callbacks.

Set up by the OffBroadway.Kafka macro.

Link to this section Summary

Functions

generation_id()

handle_messages(messages, state)

Handles Kafka messages.

Initializes Broadway pipeline for Elsa.Consumer.MessageHandler.

topic()

Link to this section Functions

connection()

generation_id()

handle_messages(messages, state)

Handles Kafka messages.

Delegates message processing to OffBroadway.Kafka.Producer.handle_messages/2.

init(args)

Initializes Broadway pipeline for Elsa.Consumer.MessageHandler.

Assumes a single producer stage using the OffBroadway.Kafka.Producer module. Other Broadway configuration comes from the OffBroadway.Kafka.broadway_config/3callback.

Retains a reference to the producer process in the state.

partition()

topic()