conduktor.io ↗

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

AuthorA. Sophie Blee-Goldman
StatusAccepted
Kafka Version2.7
JIRAKAFKA-5636
WikiView on Apache Wiki
Created2019-04-06
Last Modified2020-09-08
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.