conduktor.io ↗

KIP-508 —  Make Suppression State Queriable

Discussion Streams

Exposes interactive query access to the suppression buffer in Kafka Streams so callers can query only the finalized (emitted) records from a `KTable#suppress()` operator via a dedicated `ReadOnlyKeyValueStore`. The existing workaround of materializing the downstream table required double storage and could not provide an iterator over only the finalized state held by the suppression buffer.

Details

AuthorDongjin Lee
StatusDiscussion
JIRAKAFKA-8403
WikiView on Apache Wiki
Created2019-08-16
Last Modified2020-09-28
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.