List sink consumers

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"
          },
          ...
        ]
      }
    }
  ]
}

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

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.

Show tables properties

string

The name of the table.A 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

The column names to group by or null to disable grouping

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 Azure Event Hub properties

string

Must be “azure_event_hub”

string

Event Hub namespace

string

Event Hub name

string

Shared access key name

string

Shared access key

Show Elasticsearch properties

string

Must be “elasticsearch”

string

Elasticsearch endpoint URL

string

Elasticsearch index name

string

Authentication type (api_key, basic, bearer)

string

Authentication value

integer

Number of documents to batch together (default: 100)

Show GCP PubSub properties

string

Must be “gcp_pubsub”

string

GCP project ID

string

PubSub topic ID

string

Base64-encoded credentials

boolean

Whether to use the emulator

string

Emulator base URL if using emulator

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

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

string

Must be “kinesis”

string

Kinesis stream ARN

string

AWS access key ID

string

AWS secret access key

Show Meilisearch properties

string

Must be “meilisearch”

string

Meilisearch endpoint URL

string

Meilisearch index name

string

Primary key field name (default: “id”)

string

Meilisearch API key

integer

Number of documents to batch together (default: 100)

integer

Request timeout in seconds (default: 5)

Show NATS properties

string

Must be “nats”

string

NATS host

integer

NATS port

string

Optional username for authentication

string

Optional password for authentication

string

Optional JWT for authentication

string

Optional NKey seed for authentication

boolean

Whether to use TLS

Show RabbitMQ properties

string

Must be “rabbitmq”

string

RabbitMQ host

integer

RabbitMQ port

string

Username for authentication

string

Password for authentication

string

Virtual host name (default: ”/”)

boolean

Whether to use TLS

string

Exchange name

Show Redis Stream properties

string

Must be “redis_stream”

string

Redis host

integer

Redis port

string

Redis stream key

integer

Redis database number (default: 0)

boolean

Whether to use TLS

string

Optional username for authentication

string

Optional password for authentication

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

string

Must be “s2”

string

The name of the S2 basin

string

The name of the S2 stream

string

The access token for the S2 account associated with the basin and stream

Show Sequin Stream properties

string

Must be “sequin_stream”

Show SNS properties

string

Must be “sns”

string

SNS topic ARN

string

AWS region

string

AWS access key ID

string

AWS secret access key

boolean

Whether the topic is a FIFO topic

Show SQS properties

string

Must be “sqs”

string

SQS queue URL

string

AWS region

string

AWS access key ID

string

AWS secret access key

boolean

Whether the queue is a FIFO queue

Show Typesense properties

string

Must be “typesense”

string

Typesense endpoint URL

string

Typesense collection name

string

Typesense API key

integer

Number of documents to batch together (default: 100)

integer

Request timeout in seconds (default: 5)

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

object

Health status information for the sink consumer

Show health properties

string

Name of the health check

string

Overall health status

array

Array of individual health checks

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"
          },
          ...
        ]
      }
    }
  ]
}