Process event streams with versioned contracts, event-time windows, late corrections, replay-safe sinks and batch parity.
Learning path
- Stream event contract: identity, version and partition key
- Event-time windows: place each event by occurrence, not arrival
- Watermarks and late events: define when a window becomes final
- Idempotent streaming sinks: make retries safe across failures
- Stateful stream joins: bound waiting time and unmatched records
- Streaming operations: monitor lag, corrections and batch parity
- Project: build a replay-safe receipt event dashboard
Connected foundations
Use the earlier data and model boundaries as prerequisites.
Further paths
Practice
Continue into another subject: Anomaly Detection Tutorial.