conduktor.io ↗

KIP-326 — Schedulable KTable as Graph source

Discarded Streams

Proposes a `SchedulableKTable` that allows periodic aggregation of partial KTable state into a global summary at a configurable interval rather than on every record. When aggregating across all partitions (e.g., total spend by age group) at high throughput across many Streams instances, triggering a global rollup on every message creates an unbounded bottleneck at the aggregation point.

Details

AuthorFlavio Stutz
StatusDiscarded
WikiView on Apache Wiki
Created2018-06-25
Last Modified2025-01-04
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.