examples/

Details

Path	Synopsis
backpressure Backpressure demo: a fast source feeding a deliberately slow sink through tiny edges.	Backpressure demo: a fast source feeding a deliberately slow sink through tiny edges.
exactly-once Exactly-once pipeline: Kafka → keyed aggregation → transactional Kafka.	Exactly-once pipeline: Kafka → keyed aggregation → transactional Kafka.
kafka-orders
pg-orders
windowing
wordcount