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

string

required

The name or ID of the sink

Response fields

sink_consumer[]

Where each sink_consumer is an object with the following fields:

string

The unique identifier of the backfill

string

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

string

The name of the table that was backfilled

string

The timestamp when the backfill was created

string

The name of the sink consumer

string

The timestamp when the backfill was last updated

string

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

string

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

integer

The number of rows ingested by the backfill

integer

The initial number of rows to be processed

integer

The number of rows processed by the backfill

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