conduktor.io ↗

KIP-265 — Make Windowed Serde to public APIs

Accepted Kafka 2.0 Streams

Promotes windowed Serdes (TimeWindowedSerde, SessionWindowedSerde) from internal packages to the public o.a.k.streams.kstream package and adds DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS / DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS to StreamsConfig. Users consuming windowed KTable changelog topics had to implement their own windowed deserialization since the internal serdes were not part of the public API.

Details

AuthorGuozhang Wang
StatusAccepted
Kafka Version2.0
JIRAKAFKA-4831
WikiView on Apache Wiki
Created2018-03-01
Last Modified2018-04-16
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.