conduktor.io ↗

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

AuthorJonathan Gordon
StatusDiscussion
JIRAKAFKA-7748
WikiView on Apache Wiki
Created2019-01-23
Last Modified2020-05-01
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.