Kafka topic

Start a workflow from every message on a Kafka topic, for the platform's own workflows

trigger:kafka starts a workflow for every message on a topic.

{"id": "trigger", "name": "Audit log", "type": "trigger:kafka", "category": "trigger", "config": {"topic": "tp_audit"}}

Config	Description
`topic`	Required. The Kafka topic

trigger:kafka ignores tenants: a message starts every published workflow listening on the topic, whoever owns it. Use it for the platform's own workflows, and give tenants catalog events, which route each message to its tenant.

It needs serve with --kafka-brokers. The brokers and the consumer group (--kafka-group) come from serve, not from the node, and the topic is consumed and delivered like catalog events: see delivery.

What the trigger sends on

Field	Description
`message`	The message value parsed as JSON, or `{"raw_message": "<text>"}` when it is not JSON
`key`	The message key
`headers`	The Kafka headers
`topic`, `partition`, `offset`, `timestamp`	Where the message came from

Kafka topic

What the trigger sends on

On this page