Create Pipeline Configuration

Creates a configuration for a pipeline.

POST /api/v1/create_pipeline_configuration

Request Body (JSON):

{
  "virtual_cluster_id": "vci_xxx",
  "pipeline_id": "pipeline-xyz",
  "configuration_yaml": "
input:
    kafka_franz:
        seed_brokers: ["localhost:9092"]
        topics: ["test_topic"]
        consumer_group: "test_topic_cap"

    processors:
        - mapping: "root = content().capitalize()"

  output:
      kafka_franz:
          seed_brokers: ["localhost:9092"]
          topic: "test_topic_capitalized"
"
}

CURL Example:

curl https://api.prod.us-east-1.warpstream.com/api/v1/create_pipeline_configuration \
-H 'warpstream-api-key: XXXXXXXXXX' \
-H 'Content-Type: application/json' \
-d '{"virtual_cluster_id": "vci_1d4930d7_8e6d_4ad9_b27a_654ed4aaa3ee", "pipeline_id": "pipeline-xyz", "configuration_yaml": "source:\n  type: http\n..."}'

Response Body (JSON):

{
  "configuration_id": "config-123"
}

Last updated

Logo

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.