POST /api/v1/create_pipeline_configuration
{
"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 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..."}'
{
"configuration_id": "config-123"
}