Create Sink

Creates a new sink.

post/api/v1/stream/{stream_id}/sink

Path parameters

stream_idstring required

The Stream's ID or UID.

Example:unique-identifier

The Stream's ID or UID.

Headers

idempotency-keystring

The request's idempotency key

Request body

Example request

{
  "batchSize": 100,
  "channels": [
    "project_1337"
  ],
  "eventTypes": [
    "user.signup"
  ],
  "uid": "unique-identifier"
}

Response

Example response

{
  "channels": [
    "project_1337"
  ],
  "eventTypes": [
    "user.signup"
  ],
  "id": "sink_2yZwUhtgs5Ai8T9yRQJXA",
  "uid": "unique-identifier"
}

Changes

Changed in 3 of the 5 revisions of this API.513

Aug 28, 202650dde67d2d2d13See the full diff
- ▲
  added StreamSinkOut_postgres to the response body oneOf list for the response status 201
  response-body-one-of-added
- ○
  added postgres mapping keys to the request discriminator
  request-body-discriminator-mapping-added
- ○
  added StreamSinkIn_postgres to the request body oneOf list
  request-body-one-of-added
- ○
  added postgres mapping keys to the response discriminator for the response status 201
  response-body-discriminator-mapping-added
Aug 19, 2026dc130bd1b07426See the full diff
- ▲
  removed subschema #1 subschema #2 subschema #3 subschema #4 subschema #5 subschema #6 subschema #7 subschema #8 subschema #9 subschema #10 subschema #11 subschema #12 subschema #13 subschema #14 subschema #15 from the request body oneOf list
  request-body-one-of-removed
- ▲
  added StreamSinkOut_poller StreamSinkOut_azureBlobStorage StreamSinkOut_otelTracing StreamSinkOut_http StreamSinkOut_amazonS3 StreamSinkOut_snowflake StreamSinkOut_googleCloudStorage StreamSinkOut_googleCloudPubSub StreamSinkOut_redshift StreamSinkOut_bigQuery StreamSinkOut_clickhouse StreamSinkOut_rabbitMq StreamSinkOut_sqs StreamSinkOut_eventBridge StreamSinkOut_sns to the response body oneOf list for the response status 201
  response-body-one-of-added
- ○
  added the new optional request property channels
  new-optional-request-property
- ○
  added request discriminator
  request-body-discriminator-added
- ○
  added StreamSinkIn_poller StreamSinkIn_azureBlobStorage StreamSinkIn_otelTracing StreamSinkIn_http StreamSinkIn_amazonS3 StreamSinkIn_googleCloudStorage StreamSinkIn_googleCloudPubSub StreamSinkIn_sqs StreamSinkIn_sns StreamSinkIn_bigQuery StreamSinkIn_clickhouse StreamSinkIn_eventBridge StreamSinkIn_snowflake StreamSinkIn_rabbitMq StreamSinkIn_redshift to the request body oneOf list
  request-body-one-of-added
- ○
  added response discriminator for the response status 201
  response-body-discriminator-added
- ○
  removed subschema #1 subschema #2 subschema #3 subschema #4 subschema #5 subschema #6 subschema #7 subschema #8 subschema #9 subschema #10 subschema #11 subschema #12 subschema #13 subschema #14 subschema #15 from the response body oneOf list for the response status 201
  response-body-one-of-removed
- ○
  added the optional property channels to the response with the 201 status
  response-optional-property-added
This revision also has 36 changes that name no endpoint, such as unreferenced schemas being removed. See the revision's changelog
Jul 31, 202616dbcc056c4824See the full diff
- ▲
  removed StreamSinkIn_poller StreamSinkIn_azureBlobStorage StreamSinkIn_otelTracing StreamSinkIn_http StreamSinkIn_amazonS3 StreamSinkIn_googleCloudStorage StreamSinkIn_googleCloudPubSub StreamSinkIn_sqs StreamSinkIn_sns StreamSinkIn_bigQuery StreamSinkIn_clickhouse StreamSinkIn_eventBridge StreamSinkIn_snowflake StreamSinkIn_rabbitMq StreamSinkIn_redshift from the request body oneOf list
  request-body-one-of-removed
- ▲
  added subschema #1 subschema #2 subschema #3 subschema #4 subschema #5 subschema #6 subschema #7 subschema #8 subschema #9 subschema #10 subschema #11 subschema #12 subschema #13 subschema #14 subschema #15 to the response body oneOf list for the response status 201
  response-body-one-of-added
- ○
  removed request discriminator
  request-body-discriminator-removed
- ○
  added subschema #1 subschema #2 subschema #3 subschema #4 subschema #5 subschema #6 subschema #7 subschema #8 subschema #9 subschema #10 subschema #11 subschema #12 subschema #13 subschema #14 subschema #15 to the request body oneOf list
  request-body-one-of-added
- ○
  removed response discriminator for the response status 201
  response-body-discriminator-removed
- ○
  removed StreamSinkOut_poller StreamSinkOut_azureBlobStorage StreamSinkOut_otelTracing StreamSinkOut_http StreamSinkOut_amazonS3 StreamSinkOut_googleCloudStorage StreamSinkOut_googleCloudPubSub StreamSinkOut_sqs StreamSinkOut_sns StreamSinkOut_bigQuery StreamSinkOut_clickhouse StreamSinkOut_eventBridge StreamSinkOut_snowflake StreamSinkOut_rabbitMq StreamSinkOut_redshift from the response body oneOf list for the response status 201
  response-body-one-of-removed
This revision also has 157 changes that name no endpoint, such as unreferenced schemas being removed. See the revision's changelog

Full history