Read records from source

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.

Optional sync run identifier used to track bounded sync progress.

Optional array of input messages (push mode). Without stdin, reads from the source connector (backfill mode).