Module kafka_trigger 

Structs

KafkaTrigger

Enums

AutoOffsetReset

Initial offset behavior when consumer group has no committed offset. ‘latest’ starts from new messages only, ‘earliest’ starts from the beginning.

FilterLogic

Logic to apply when evaluating the top-level filters. ‘and’ requires all of them to match, ‘or’ requires any of them to match. Nested any_of/all_of/none_of groups carry their own logic.