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
| Author | Flavio Stutz |
| Status | Discarded |
| Wiki | View on Apache Wiki |
| Created | 2018-06-25 |
| Last Modified | 2025-01-04 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.