conduktor.io ↗

KIP-446 — Add changelog topic configuration to KTable suppress

Accepted Kafka 2.7 Streams

Adds a `Suppressed.withLoggingDisabled()` option and a `Materialized`-style `SuppressedInternal` configuration to allow users to configure the changelog topic created for a `KTable.suppress()` operation, including setting `cleanup.policy=delete` with a shorter retention. The suppress operator's changelog topic inherits the same aggressive compaction defaults as other KTable changelogs, but suppress data is short-lived and highly compactable, wasting storage and increasing compaction load.

Details

AuthorMaarten Duijn
StatusAccepted
Kafka Version2.7
JIRAKAFKA-8147
WikiView on Apache Wiki
Created2019-03-25
Last Modified2020-02-25
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.