Stateless Sync API
Read records from source
Streams NDJSON messages (records, state, catalog). Optional NDJSON body provides live events as input.
post/pipeline_read
Query parameters
state_limitinteger
Stop streaming after N state messages.
Stop streaming after N state messages.
time_limitnumber
Stop streaming after N seconds.
Stop streaming after N seconds.
run_idstring
Optional sync run identifier used to track bounded sync progress.
Example:run_demo
Optional sync run identifier used to track bounded sync progress.
Headers
JSON-encoded PipelineConfig
JSON-encoded SyncState ({ source, destination, sync_run }). Falls back to empty state if invalid.
Response
NDJSON stream of sync messages