KIP-450 — Sliding Window Aggregations in the DSL
Accepted Kafka 2.7 Streams
Adds a `SlidingWindows` window type to the Kafka Streams DSL, inclusive on both start and end time, exposed through new `windowedBy(SlidingWindows)` overloads on `KGroupedStream` and `CogroupedKStream`. Emulating sliding aggregation with hopping windows advanced by 1 ms produces many overlapping and often redundant windows whose aggregates are recomputed each time, whereas sliding windows compute each distinct window exactly once.
Details
| Author | A. Sophie Blee-Goldman |
| Status | Accepted |
| Kafka Version | 2.7 |
| JIRA | KAFKA-5636 |
| Wiki | View on Apache Wiki |
| Created | 2019-04-06 |
| Last Modified | 2020-09-08 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.