Skip to main content
connectors/stdout writes records to stdout instead of a real destination. It shows up in the embedding example alongside the PostgreSQL source as the fastest way to see a pipeline run end-to-end with no external sink to configure.

Output shape

Each record prints as one NDJSON line — {"id", "op", "data"} — and Commit prints a final # {...} summary line (prefixed with # so it’s distinguishable from the data lines on the same stream) with the per-resource record and byte counts for the run. It’s also the reference implementation a real sink is checked against: no buffering or transactional state beyond per-run accounting, so Abort is just a marker — about as simple as filament.Sink gets.

Modes

Supports Append and SnapshotReplace write policies (see Replication modes).