Apache Kafka Triggers¶

AwaitMessageTrigger¶

The AwaitMessageTrigger is a trigger that will consume messages polled from a Kafka topic and process them with a provided callable. If the callable returns any data, a TriggerEvent is raised.

For parameter definitions take a look at AwaitMessageTrigger.

KafkaMessageQueueTrigger¶

The KafkaMessageQueueTrigger is a dedicated interface class for Kafka message queues that extends the common MessageQueueTrigger. It is designed to work with the KafkaMessageQueueProvider and provides a more specific interface for Kafka message queue operations while leveraging the unified messaging framework.

For parameter definitions take a look at KafkaMessageQueueTrigger

For how to use the trigger, refer to the documentation of the Apache Kafka Message Queue Trigger