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 SourceState ({ streams, global }) or legacy flat per-stream state
Response
NDJSON stream of sync messages