Sign in
Stateless Sync API

Read records from source

Streams NDJSON messages (records, state, catalog).

post/pipeline_read

Request body

time_limitnumber

Stop streaming after N seconds.

soft_time_limitnumber

Soft wall-clock deadline in seconds. Stops reading from the source between messages; the destination continues to drain and flush until time_limit fires.

run_idstring

Optional sync run identifier used to track bounded sync progress.

Example request

{
  "time_limit": 300,
  "soft_time_limit": 150,
  "run_id": "run_demo"
}

Response

NDJSON stream of sync messages

Changes