Create Pipeline Configuration
Creates a configuration for a pipeline.
POST /api/v1/create_pipeline_configurationRequest 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?