1// pipeline.ts2export const ingest = createPipeline({3 source: kafka('events.raw'),4 schema: EventSchema,5 transform: normalize<Event>(),6 sink: warehouse('events'),7})89// 4.2M rows / hour · p95 82ms
Distributed Ingestion Refactor
Consolidated a fragmented ETL surface into an idempotent, schema-driven pipeline.


