KIP-328 — Ability to suppress updates for KTables

Accepted Streams

Introduces `KTable#suppress()` to Kafka Streams so that a KTable can buffer intermediate updates and emit only final or time-delimited results downstream, replacing the cache-based deduplication with an explicit, event-time-aware suppression operator. The existing record cache provided only a best-effort, commit-interval-based suppression that could not guarantee that only a single final result per key was emitted within a time window.

Details