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.