conduktor.io ↗

KIP-393 — Time windowed serde to properly deserialize changelog input topic

Accepted Kafka 2.2 Streams

Fixes `TimeWindowedDeserializer` to correctly decode windowed keys read from Streams changelog topics by accounting for the sequence number appended by `WindowKeySchema` during serialization. The existing `TimeWindowedSerde` uses `WindowKeySchema.fromStoreKey()` which does not strip the sequence number, producing incorrect window timestamps when a Streams application reads back its own changelog.

Details

AuthorShawn Nguyen
StatusAccepted
Kafka Version2.2
JIRAKAFKA-7110
WikiView on Apache Wiki
Created2018-11-25
Last Modified2019-01-16
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.