conduktor.io ↗

KIP-659 — Improve TimeWindowedDeserializer and TimeWindowedSerde to handle window size

Accepted Kafka 2.8 Streams

Adds a `window.size.ms` config to `StreamsConfig` and deprecates the no-arg constructors of `TimeWindowedSerde`/`TimeWindowedDeserializer` that default window size to `Long.MAX_VALUE`, making window size explicit. Without window size being passed through, consumers performing windowed aggregations initialize deserializers with `Long.MAX_VALUE` as window size, causing incorrect window-end time calculations and runtime errors.

Details

AuthorLeah Thomas
StatusAccepted
Kafka Version2.8
JIRAKAFKA-10366
WikiView on Apache Wiki
Created2020-08-19
Last Modified2021-01-21
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.