conduktor.io ↗

KIP-747 — Add support for basic aggregation APIs

Discussion Streams

Adds built-in `min`, `max`, and `sum` aggregation functions to `KGroupedStream`, `KGroupedTable`, `TimeWindowedKStream`, and `SessionWindowedKStream` in Kafka Streams. Developers currently must implement these common aggregations manually in every application, leading to duplicated, potentially suboptimal code scattered across codebases.

Details

AuthorMohan Parthasarathy
StatusDiscussion
WikiView on Apache Wiki
Created2021-05-11
Last Modified2021-06-08
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.