Chapter 6: Deterministic Stream Processing
Determinism with Event-Driven Workflows
Timestamps
Event Scheduling and Deterministic Processing
Custom Event Schedulers
Processing Based on Event Time, Processing Time, and Ingestion Time
Timestamp Extraction by the Consumer
Request-Response Calls to External Systems
Watermarks
Stream Time
Out-of-Order and Late-Arriving Events
Late Events with Watermarks and Stream Time
Causes and Impacts of Out-of-Order Events
Time-Sensitive Functions and Windowing
Tumbling windows
Sliding windows
Session windows
Handling Late Events
Reprocessing Versus Processing in Near-Real Time
Intermittent Failures and Late Events
Producer/Event Broker Connectivity Issues
Summary and Further Reading