KIP-424 — Allow suppression of intermediate events based on wall clock time
Discussion Streams
Extends Kafka Streams' KTable suppress operator with a wall-clock-time-based suppression option (via `Suppressed.untilTimeLimit(Duration, BufferConfig)`) in addition to the existing stream-time-based semantics. Stream-time-based suppression stalls indefinitely if no new events arrive, making it unusable for rate-capping aggregate emission in sparse or bursty IoT workloads where real time must govern flush cadence.
Details
| Author | Jonathan Gordon |
| Status | Discussion |
| JIRA | KAFKA-7748 |
| Wiki | View on Apache Wiki |
| Created | 2019-01-23 |
| Last Modified | 2020-05-01 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.