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.
Headers
JSON-encoded PipelineConfig
JSON-encoded SyncState ({ source, destination, engine }) or legacy SourceState/flat formats
Response
NDJSON stream of sync messages