List backfills

curl -X GET "https://api.sequinstream.com/api/sinks/kafka-ids/backfills" \
  -H "Authorization: Bearer YOUR_API_TOKEN"

{
  "data": [
    {
      "id": "e0c918bb-12a2-4810-94a3-387cd672a478",
      "state": "completed",
      "table": "public.benchmark_records",
      "inserted_at": "2025-04-09T04:06:23Z",
      "sink_consumer": "kafka-ids",
      "updated_at": "2025-04-09T04:06:28Z",
      "canceled_at": null,
      "completed_at": "2025-04-09T04:06:28.000000Z",
      "rows_ingested_count": 54700,
      "rows_initial_count": 54700,
      "rows_processed_count": 54700,
      "sort_column": "benchmark_records"
    }
  ]
}

{
  "data": [
    {
      "id": "<string>",
      "state": "<string>",
      "table": "<string>",
      "inserted_at": "<string>",
      "sink_consumer": "<string>",
      "updated_at": "<string>",
      "canceled_at": "<string>",
      "completed_at": "<string>",
      "rows_ingested_count": 123,
      "rows_initial_count": 123,
      "rows_processed_count": 123,
      "sort_column": "<string>"
    }
  ]
}

GET

sinks

{sink_id_or_name}

backfills

curl -X GET "https://api.sequinstream.com/api/sinks/kafka-ids/backfills" \
  -H "Authorization: Bearer YOUR_API_TOKEN"

{
  "data": [
    {
      "id": "e0c918bb-12a2-4810-94a3-387cd672a478",
      "state": "completed",
      "table": "public.benchmark_records",
      "inserted_at": "2025-04-09T04:06:23Z",
      "sink_consumer": "kafka-ids",
      "updated_at": "2025-04-09T04:06:28Z",
      "canceled_at": null,
      "completed_at": "2025-04-09T04:06:28.000000Z",
      "rows_ingested_count": 54700,
      "rows_initial_count": 54700,
      "rows_processed_count": 54700,
      "sort_column": "benchmark_records"
    }
  ]
}

{
  "data": [
    {
      "id": "<string>",
      "state": "<string>",
      "table": "<string>",
      "inserted_at": "<string>",
      "sink_consumer": "<string>",
      "updated_at": "<string>",
      "canceled_at": "<string>",
      "completed_at": "<string>",
      "rows_ingested_count": 123,
      "rows_initial_count": 123,
      "rows_processed_count": 123,
      "sort_column": "<string>"
    }
  ]
}

Returns a list of all backfills for a specific sink.

Request fields

sink_id_or_name

string

required

The name or ID of the sink

Response fields

data

sink_consumer[]

Where each sink_consumer is an object with the following fields:

string

The unique identifier of the backfill

state

string

The current state of the backfill (active, completed, cancelled)

table

string

The name of the table that was backfilled

inserted_at

string

The timestamp when the backfill was created

sink_consumer

string

The name of the sink consumer

updated_at

string

The timestamp when the backfill was last updated

canceled_at

string

The timestamp when the backfill was cancelled (null if not cancelled)

completed_at

string

The timestamp when the backfill was completed (null if not completed)

rows_ingested_count

integer

The number of rows ingested by the backfill

rows_initial_count

integer

The initial number of rows to be processed

rows_processed_count

integer

The number of rows processed by the backfill

sort_column

string

The column used for sorting the backfill data

curl -X GET "https://api.sequinstream.com/api/sinks/kafka-ids/backfills" \
  -H "Authorization: Bearer YOUR_API_TOKEN"

{
  "data": [
    {
      "id": "e0c918bb-12a2-4810-94a3-387cd672a478",
      "state": "completed",
      "table": "public.benchmark_records",
      "inserted_at": "2025-04-09T04:06:23Z",
      "sink_consumer": "kafka-ids",
      "updated_at": "2025-04-09T04:06:28Z",
      "canceled_at": null,
      "completed_at": "2025-04-09T04:06:28.000000Z",
      "rows_ingested_count": 54700,
      "rows_initial_count": 54700,
      "rows_processed_count": 54700,
      "sort_column": "benchmark_records"
    }
  ]
}

Delete sink consumer Get backfill

​Request fields

​Response fields

Request fields

Response fields