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

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

Creates a new backfill for a specific sink. The backfill will be created in the active state.

​
Request fields

​
sink_id_or_name
string
required

The name or ID of the sink

​
table
string

The source table for the backfill in the format schema.table or table (schema defaults to public)

Must specify this parameter if the sink is configured to stream changes from all tables in a schema.

​
Response fields

​
id
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 POST "https://api.sequinstream.com/api/sinks/kafka-ids/backfills" \
  -H "Authorization: Bearer YOUR_API_TOKEN"