Apache Kafka 触发器¶

AwaitMessageTrigger¶

AwaitMessageTrigger 是一个触发器，它将消费从 Kafka 主题轮询的消息，并使用提供的可调用对象（callable）对其进行处理。如果该可调用对象返回任何数据，则会触发一个 TriggerEvent。

有关参数定义，请参阅 AwaitMessageTrigger。