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:

Response Body (JSON):

Last updated

Was this helpful?