Read records from source
Streams NDJSON messages (records, state, catalog). Optional NDJSON body provides live events as input.
Query parameters
Stop streaming after N seconds.
Stop streaming after N seconds.
Soft wall-clock deadline in seconds. Stops reading from the source between messages; the destination continues to drain and flush until time_limit fires.
Soft wall-clock deadline in seconds. Stops reading from the source between messages; the destination continues to drain and flush until time_limit fires.
Optional sync run identifier used to track bounded sync progress.
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