---
title: "update kafka trigger"
method: POST
path: "/w/{workspace}/kafka_triggers/update/{path}"
tags: ["kafka_trigger"]
---

# update kafka trigger

`POST /w/{workspace}/kafka_triggers/update/{path}`

## Path parameters

- `workspace` string, required
- `path` string, required

## Request body

- EditKafkaTrigger
  - `kafka_resource_path` string, required — Path to the Kafka resource containing connection configuration
  - `group_id` string, required — Kafka consumer group ID for this trigger
  - `topics` string[], required — Array of Kafka topic names to subscribe to
  - `filters` object[], required
    - `key` string, required
    - `value` unknown, required
  - `filter_logic` 'and' | 'or' — Logic to apply when evaluating filters. 'and' requires all filters to match, 'or' requires any filter to match.
  - `auto_offset_reset` 'latest' | 'earliest' — Initial offset behavior when consumer group has no committed offset.
  - `auto_commit` boolean — When true (default), offsets are committed automatically after receiving each message. When false, you must manually commit offsets using the commit_offsets endpoint.
  - `path` string, 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_path` string, required — Path to the script or flow to execute when a message is received
  - `is_flow` boolean, required — True if script_path points to a flow, false if it points to a script
  - `error_handler_path` string — Path to a script or flow to run when the triggered job fails
  - `error_handler_args` ScriptArgs — The arguments to pass to the script or flow
  - `retry` Retry — unresolved $ref
  - `permissioned_as` string — The user or group this trigger runs as. Used during deployment to preserve the original trigger owner.
  - `preserve_permissioned_as` boolean — When true and the caller is a member of the 'wm_deployers' group, preserves the original permissioned_as value instead of overwriting it.
  - `labels` string[]

## Response `200`

kafka trigger updated

---

[API](https://skmtc.net/windmill/apis/windmill-api.md) · [All operations](https://skmtc.net/windmill/apis/windmill-api/llms.txt) · [OpenAPI document](https://skmtc-service-staging.skmtc.workers.dev/v1/apis/windmill/windmill-api/revisions/964225251155/schema)