latestOpenAPI 3.0.3Apache 2.0raw.githubusercontent.com2026-08-158263541004.1 KB

a7f071808448

kafka_trigger

update kafka trigger

post/w/{workspace}/kafka_triggers/update/{path}

Path parameters

workspacestring required
pathstring required

Request body

kafka_resource_pathstring required

Path to the Kafka resource containing connection configuration

group_idstring required

Kafka consumer group ID for this trigger

topicsstring[] required

Array of Kafka topic names to subscribe to

filter_logic'and' | 'or'

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.

auto_offset_reset'latest' | 'earliest'

Initial offset behavior when consumer group has no committed offset.

auto_commitboolean

When true (default), offsets are committed automatically after receiving each message. When false, you must manually commit offsets using the commit_offsets endpoint.

pathstring required

The unique Windmill path for this trigger. Must be of the form u/<user>/<path> or f/<folder>/<path>. This is the trigger object path, not the HTTP route path.

script_pathstring required

Path to the script or flow to execute when a message is received

is_flowboolean required

True if script_path points to a flow, false if it points to a script

error_handler_pathstring

Path to a script or flow to run when the triggered job fails

error_handler_argsScriptArgs

The arguments to pass to the script or flow

retryRetry — unresolved $ref
permissioned_asstring

The user or group this trigger runs as. Used during deployment to preserve the original trigger owner.

preserve_permissioned_asboolean

When true and the caller is a member of the 'wm_deployers' group, preserves the original permissioned_as value instead of overwriting it.

labelsstring[]

Response

kafka trigger updated