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
| Author | Shawn Nguyen |
| Status | Accepted |
| Kafka Version | 2.2 |
| JIRA | KAFKA-7110 |
| Wiki | View on Apache Wiki |
| Created | 2018-11-25 |
| Last Modified | 2019-01-16 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.