cURL
curl --request POST \ --url https://api.streamkap.com/transforms \ --header 'Authorization: Bearer <token>' \ --header 'Content-Type: application/json' \ --data ' { "transform": "fan_out", "config": { "transforms.name": "<string>", "transforms.input.topic.pattern": "<string>", "transforms.output.topic.pattern": "<string>", "transforms.input.serialization.format": "Any", "transforms.output.serialization.format": "Any", "transforms.language": "<string>", "transforms.input.job.parallelism": 5 }, "created_from": "api" } '
{ "id": "<string>", "name": "<string>", "sub_id": "<string>", "tenant_id": "<string>", "transform_type": "fan_out", "config": { "transforms.name": "<string>", "transforms.input.topic.pattern": "<string>", "transforms.output.topic.pattern": "<string>", "transforms.input.serialization.format": "Any", "transforms.output.serialization.format": "Any", "transforms.language": "<string>", "transforms.input.job.parallelism": 5 }, "service_id": "<string>", "start_time": "<string>", "job_name": "<string>", "topic_ids": "<string>", "implementation": { "language": "PYTHON", "value_transform": "<string>", "key_transform": "<string>", "topic_transform": "<string>", "unit_test": { "test_name": "<string>", "input__json": [ { "topic": "<string>", "value": {}, "key": {}, "timestamp": "2023-11-07T05:31:56Z" } ], "output__json": [ { "topic": "<string>", "value": {}, "key": {}, "timestamp": "2023-11-07T05:31:56Z" } ], "result__json": [ { "topic": "<string>", "value": {}, "key": {}, "timestamp": "2023-11-07T05:31:56Z" } ], "is_success": true, "html_diff": "<string>", "text_diff": "<string>" } }, "metrics": { "tasks": 123, "latency": 123, "status": "<string>", "duration": 123, "start_time": 123, "end_time": "<string>" }, "live_version": "<string>", "preview_version": "<string>", "version": 1, "updated_timestamp": "2023-11-07T05:31:56Z", "implementation_updated_timestamp": "2023-11-07T05:31:56Z" }
Bearer authentication header of the form Bearer <token>, where <token> is your auth token.
Bearer <token>
<token>
fan_out
sql_join
enrich
enrich_async
map_filter
toast_handling
un_nesting
Show child attributes
Any
Json
Avro
terraform
web
api
Successful Response
Basic transform details.
PYTHON
JAVASCRIPT
SQL
Was this page helpful?