Clear a node's or workflow's queue
POST/api/clear_queue
Advances the consumer group offset to the high watermark for a node (node_id given) or every consuming node in a workflow (node_id omitted), skipping past all queued messages. Returns 409 if a target node is still running, since its offset can't be changed while it consumes.
Request
Responses
- 200
- 404
- 409
- 422
- 503
Successful Response
Node not found / Workflow not found
Stop the node before clearing its queue:
Validation Error
Kafka broker unavailable