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
| Author | Leah Thomas |
| Status | Accepted |
| Kafka Version | 2.8 |
| JIRA | KAFKA-10366 |
| Wiki | View on Apache Wiki |
| Created | 2020-08-19 |
| Last Modified | 2021-01-21 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.