Delete stream
Stop (if currently running) and permanently detach/delete a `kafka`/`nats` Data Source from a project. If the consumer task is already stopped, this still cleans up the stream's persisted position marker.
Stop (if currently running) and permanently detach/delete a kafka/nats
Data Source from a project. If the consumer task is already stopped,
this still cleans up the stream's persisted position marker.
Authorization
SymetryMLAuth HMAC-SHA256 signature-based authentication: requests are signed with
your secret key and sent with the Customer-ID, Sym-date,
Authorization, Content-MD5 and sym-version headers.
See SymetryML REST API Security
for the signature algorithm and a complete example.
In: header
Path Parameters
User/Customer identifier
Project identifier
Data source name
Response Body
application/json
application/json
application/json
curl -X DELETE "https://example.com/c1/projects/nbra_prj_iris/streams/nbra_ds_sftp_iris"{ "statusCode": 200, "statusString": "OK", "values": {}}{ "statusCode": 400, "statusString": "Customer [c1]: no SML [nosuchprj]", "values": {}}{ "statusCode": 500, "statusString": "Generic Exception [java.lang.NullPointerException: Cannot invoke \"com.rtlm.json.DSInfo.getType()\" because \"sinfo\" is null]", "values": {}}Create stream POST
Attach a new `kafka` or `nats` Data Source to a project and immediately start a background consumer task for it. This both creates the DS entry and starts consuming in one call — there is no separate "create, then start" step for a brand-new stream (use [Start stream](/docs/api-reference/streams/projects-project-streams-dsname-start-get)/ [Stop stream](/docs/api-reference/streams/projects-project-streams-dsname-stop-get) only to resume/suspend an existing one).
Get stream error log GET
Return the accumulated list of error messages logged by a running stream's consumer task. Requires the stream to currently be running — a stopped or never-started stream returns a `500`, not an empty log.