Create Pipeline

Creates a new pipeline in a virtual cluster.

POST /api/v1/create_pipeline

Request Body (JSON):

  "virtual_cluster_id": "vci_xxx",
  "pipeline_name": "my-pipeline"

CURL Example:

curl \
-H 'warpstream-api-key: XXXXXXXXXX' \
-H 'Content-Type: application/json' \
-d '{"virtual_cluster_id": "vci_xxx", "pipeline_name": "my-pipeline"}'

Response Body (JSON):

  "pipeline_id": "pipeline-xyz",
  "pipeline_name": "my-pipeline",
  "pipeline_state": "paused",
  "pipeline_type": "bento",
  "pipeline_deployed_configuration_id": "" // Initially empty

Last updated


Apache, Apache Kafka, Kafka, and associated open source project names are trademarks of the Apache Software Foundation. Kinesis is a trademark of Amazon Web Services.