Create Pipeline Configuration
Creates a configuration for a pipeline.
POST /api/v1/create_pipeline_configurationRequest Body (JSON):
Section titled “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:
Section titled “CURL Example:”curl https://api.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):
Section titled “Response Body (JSON):”{ "configuration_id": "config-123"}