curl -X GET "https://api.sequinstream.com/api/sinks" \
-H "Authorization: Bearer YOUR_API_TOKEN"
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-kafka-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "kafka",
"hosts": "localhost:9092",
"tls": false,
"topic": "records",
"username": "kafka_user",
"password": "kafka_password",
"sasl_mechanism": "PLAIN"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-sqs-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "sqs",
"queue_url": "https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue",
"region": "us-east-1",
"access_key_id": "AKIAIOSFODNN7EXAMPLE",
"secret_access_key": "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-rabbitmq-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "rabbitmq",
"host": "localhost",
"port": 5672,
"username": "guest",
"password": "guest",
"virtual_host": "/",
"tls": false,
"exchange": "records"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-redis-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "redis_stream",
"host": "localhost",
"port": 6379,
"stream_key": "records",
"database": 0,
"tls": false,
"username": "redis_user",
"password": "redis_password"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-azure-event-hub-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "azure_event_hub",
"namespace": "my-namespace",
"event_hub_name": "records",
"shared_access_key_name": "RootManageSharedAccessKey",
"shared_access_key": "your-shared-access-key"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-nats-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "nats",
"host": "localhost",
"port": 4222,
"username": "nats_user",
"password": "nats_password",
"jwt": "your-jwt-token",
"nkey_seed": "your-nkey-seed",
"tls": false
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-gcp-pubsub-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "gcp_pubsub",
"project_id": "my-project",
"topic_id": "records",
"credentials": "base64-encoded-credentials",
"use_emulator": false,
"emulator_base_url": "http://localhost:8085"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-sequin-stream-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "sequin_stream"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-webhook-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "webhook",
"http_endpoint": "my-endpoint",
"http_endpoint_path": "/webhook",
"batch": true
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-elasticsearch-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "elasticsearch",
"endpoint_url": "http://localhost:9200",
"index_name": "records",
"auth_type": "basic",
"auth_value": "base64-encoded-credentials",
"batch_size": 100
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-kinesis-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "kinesis",
"stream_arn": "arn:aws:kinesis:us-east-1:123456789012:stream/my-stream",
"access_key_id": "AKIAIOSFODNN7EXAMPLE",
"secret_access_key": "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-meilisearch-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "meilisearch",
"endpoint_url": "http://localhost:7700",
"index_name": "records",
"primary_key": "id",
"api_key": "your-api-key",
"batch_size": 100,
"timeout_seconds": 5
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-redis-string-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "redis_string",
"host": "localhost",
"port": 6379,
"database": 0,
"tls": false,
"username": "redis_user",
"password": "redis_password",
"expire_ms": 3600000,
"mode": "static"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-sns-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "sns",
"topic_arn": "arn:aws:sns:us-east-1:123456789012:MyTopic",
"region": "us-east-1",
"access_key_id": "AKIAIOSFODNN7EXAMPLE",
"secret_access_key": "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY",
"is_fifo": false
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-typesense-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "typesense",
"endpoint_url": "http://localhost:8108",
"collection_name": "records",
"api_key": "your-api-key",
"batch_size": 100,
"timeout_seconds": 5
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
Sink consumers
List sink consumers
GET
/
sinks
curl -X GET "https://api.sequinstream.com/api/sinks" \
-H "Authorization: Bearer YOUR_API_TOKEN"
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-kafka-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "kafka",
"hosts": "localhost:9092",
"tls": false,
"topic": "records",
"username": "kafka_user",
"password": "kafka_password",
"sasl_mechanism": "PLAIN"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-sqs-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "sqs",
"queue_url": "https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue",
"region": "us-east-1",
"access_key_id": "AKIAIOSFODNN7EXAMPLE",
"secret_access_key": "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-rabbitmq-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "rabbitmq",
"host": "localhost",
"port": 5672,
"username": "guest",
"password": "guest",
"virtual_host": "/",
"tls": false,
"exchange": "records"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-redis-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "redis_stream",
"host": "localhost",
"port": 6379,
"stream_key": "records",
"database": 0,
"tls": false,
"username": "redis_user",
"password": "redis_password"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-azure-event-hub-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "azure_event_hub",
"namespace": "my-namespace",
"event_hub_name": "records",
"shared_access_key_name": "RootManageSharedAccessKey",
"shared_access_key": "your-shared-access-key"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-nats-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "nats",
"host": "localhost",
"port": 4222,
"username": "nats_user",
"password": "nats_password",
"jwt": "your-jwt-token",
"nkey_seed": "your-nkey-seed",
"tls": false
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-gcp-pubsub-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "gcp_pubsub",
"project_id": "my-project",
"topic_id": "records",
"credentials": "base64-encoded-credentials",
"use_emulator": false,
"emulator_base_url": "http://localhost:8085"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-sequin-stream-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "sequin_stream"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-webhook-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "webhook",
"http_endpoint": "my-endpoint",
"http_endpoint_path": "/webhook",
"batch": true
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-elasticsearch-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "elasticsearch",
"endpoint_url": "http://localhost:9200",
"index_name": "records",
"auth_type": "basic",
"auth_value": "base64-encoded-credentials",
"batch_size": 100
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-kinesis-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "kinesis",
"stream_arn": "arn:aws:kinesis:us-east-1:123456789012:stream/my-stream",
"access_key_id": "AKIAIOSFODNN7EXAMPLE",
"secret_access_key": "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-meilisearch-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "meilisearch",
"endpoint_url": "http://localhost:7700",
"index_name": "records",
"primary_key": "id",
"api_key": "your-api-key",
"batch_size": 100,
"timeout_seconds": 5
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-redis-string-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "redis_string",
"host": "localhost",
"port": 6379,
"database": 0,
"tls": false,
"username": "redis_user",
"password": "redis_password",
"expire_ms": 3600000,
"mode": "static"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-sns-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "sns",
"topic_arn": "arn:aws:sns:us-east-1:123456789012:MyTopic",
"region": "us-east-1",
"access_key_id": "AKIAIOSFODNN7EXAMPLE",
"secret_access_key": "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY",
"is_fifo": false
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-typesense-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "typesense",
"endpoint_url": "http://localhost:8108",
"collection_name": "records",
"api_key": "your-api-key",
"batch_size": 100,
"timeout_seconds": 5
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
Returns a list of all sink consumers.
Response fields
data[]
Where data is an array of objects with the following fields:
string
The unique identifier of the sink consumer
string
The name of the sink consumer
string
The current status of the sink consumer (active, disabled, paused)
string
The source database for the sink consumer
object
The source configuration for the sink consumer. This determines which tables are consumed.
Show source properties
Show source properties
array
List of schemas to include, or null to include all
array
List of schemas to exclude, or null to exclude none
array
List of tables to include, or null to include allA table name can be specified with schema (e.g.
my-schema.my-table) or without (e.g. my-table) which defaults to schema public.array
List of tables to exclude, or null to exclude noneA table name can be specified with schema (e.g.
my-schema.my-table) or without (e.g. my-table) which defaults to schema public.array
Additional configuration for individual tables.To configure which tables are consumed, see the
source field.array
The database actions to include in the sink (insert, update, delete)
object
The destination configuration for the sink consumer. The shape varies by destination type.
Show destination properties
Show destination properties
Show Azure Event Hub properties
Show Azure Event Hub properties
Show Elasticsearch properties
Show Elasticsearch properties
Show GCP PubSub properties
Show GCP PubSub properties
Show Webhook properties
Show Webhook properties
string
Must be “webhook”
string
HTTP endpoint name
string
HTTP endpoint path
boolean
Whether the webhook body should be wrapped in a list to support batching.
Show Kafka properties
Show Kafka properties
string
Must be “kafka”
string
Comma-separated list of Kafka hosts
boolean
Whether to use TLS
string
Kafka topic name
string
Optional username for authentication
string
Optional password for authentication
string
Optional SASL mechanism (plain, scram_sha_256, scram_sha_512, aws_msk_iam)
string
AWS region (required for aws_msk_iam)
string
AWS access key ID (required for aws_msk_iam)
string
AWS secret access key (required for aws_msk_iam)
Show Kinesis properties
Show Kinesis properties
Show Meilisearch properties
Show Meilisearch properties
Show NATS properties
Show NATS properties
Show RabbitMQ properties
Show RabbitMQ properties
Show Redis Stream properties
Show Redis Stream properties
Show Redis String properties
Show Redis String properties
string
Must be “redis_string”
string
Redis host
integer
Redis port
integer
Redis database number (default: 0)
boolean
Whether to use TLS
string
Optional username for authentication
string
Optional password for authentication
integer
Optional TTL in milliseconds for the keys
string
Mode of operation (static or dynamic, default: static)
Show S2 properties
Show S2 properties
Show Sequin Stream properties
Show Sequin Stream properties
string
Must be “sequin_stream”
Show SNS properties
Show SNS properties
Show SQS properties
Show SQS properties
string
The filter function for the sink consumer
string
The transform function for the sink consumer
string
The routing function for the sink consumer
string
The enrichment function for the sink consumer
boolean
Whether message grouping is enabled for delivery orderingSee message grouping and ordering for more details.
integer
The maximum number of times a message will be retried if delivery fails
object
User-defined annotations for the sink consumer
array
Array of active backfill IDs
integer
Number of records to batch together (1-1000)
string
Determines how Sequin handles overload when sink consumers can’t keep up with incoming messages
string
The format of the timestamp in the source data
curl -X GET "https://api.sequinstream.com/api/sinks" \
-H "Authorization: Bearer YOUR_API_TOKEN"
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-kafka-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "kafka",
"hosts": "localhost:9092",
"tls": false,
"topic": "records",
"username": "kafka_user",
"password": "kafka_password",
"sasl_mechanism": "PLAIN"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-sqs-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "sqs",
"queue_url": "https://sqs.us-east-1.amazonaws.com/123456789012/MyQueue",
"region": "us-east-1",
"access_key_id": "AKIAIOSFODNN7EXAMPLE",
"secret_access_key": "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-rabbitmq-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "rabbitmq",
"host": "localhost",
"port": 5672,
"username": "guest",
"password": "guest",
"virtual_host": "/",
"tls": false,
"exchange": "records"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-redis-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "redis_stream",
"host": "localhost",
"port": 6379,
"stream_key": "records",
"database": 0,
"tls": false,
"username": "redis_user",
"password": "redis_password"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-azure-event-hub-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "azure_event_hub",
"namespace": "my-namespace",
"event_hub_name": "records",
"shared_access_key_name": "RootManageSharedAccessKey",
"shared_access_key": "your-shared-access-key"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-nats-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "nats",
"host": "localhost",
"port": 4222,
"username": "nats_user",
"password": "nats_password",
"jwt": "your-jwt-token",
"nkey_seed": "your-nkey-seed",
"tls": false
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-gcp-pubsub-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "gcp_pubsub",
"project_id": "my-project",
"topic_id": "records",
"credentials": "base64-encoded-credentials",
"use_emulator": false,
"emulator_base_url": "http://localhost:8085"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-sequin-stream-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "sequin_stream"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-webhook-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "webhook",
"http_endpoint": "my-endpoint",
"http_endpoint_path": "/webhook",
"batch": true
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-elasticsearch-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "elasticsearch",
"endpoint_url": "http://localhost:9200",
"index_name": "records",
"auth_type": "basic",
"auth_value": "base64-encoded-credentials",
"batch_size": 100
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-kinesis-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "kinesis",
"stream_arn": "arn:aws:kinesis:us-east-1:123456789012:stream/my-stream",
"access_key_id": "AKIAIOSFODNN7EXAMPLE",
"secret_access_key": "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-meilisearch-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "meilisearch",
"endpoint_url": "http://localhost:7700",
"index_name": "records",
"primary_key": "id",
"api_key": "your-api-key",
"batch_size": 100,
"timeout_seconds": 5
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-redis-string-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "redis_string",
"host": "localhost",
"port": 6379,
"database": 0,
"tls": false,
"username": "redis_user",
"password": "redis_password",
"expire_ms": 3600000,
"mode": "static"
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-sns-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "sns",
"topic_arn": "arn:aws:sns:us-east-1:123456789012:MyTopic",
"region": "us-east-1",
"access_key_id": "AKIAIOSFODNN7EXAMPLE",
"secret_access_key": "wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY",
"is_fifo": false
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
{
"data": [
{
"id": "4ed2a8e5-47a7-4b51-9270-d2f4fdcb94fb",
"name": "my-typesense-sink",
"status": "active",
"database": "my-database",
"source": {
"include_schemas": null,
"exclude_schemas": null,
"include_tables": null,
"exclude_tables": null
},
"tables": [
{
"name": "public.products",
"group_column_names": ["category"]
}
],
"actions": ["insert", "update", "delete"],
"destination": {
"type": "typesense",
"endpoint_url": "http://localhost:8108",
"collection_name": "records",
"api_key": "your-api-key",
"batch_size": 100,
"timeout_seconds": 5
},
"filter": "none",
"transform": "id-transform",
"routing": "none",
"enrichment": "none",
"message_grouping": true,
"max_retry_count": null,
"annotations": {},
"active_backfills": [],
"batch_size": 50,
"load_shedding_policy": "pause_on_full",
"timestamp_format": "iso8601",
"health": {
"name": "Consumer health",
"status": "healthy",
"checks": [
{
"name": "Sink configuration",
"status": "healthy"
},
...
]
}
}
]
}
⌘I