Hi Leah, Could you explain a bit more why we do not wish to let TimeWindowedDeserializer and WindowedSerdes be created without a specified time as a parameter?
I understand the long.MAX_VALUE could cause problems but would it not be a good idea to have a usable default or fetch from the config if available? After all you are proposing to add "window.size.ms" We definitely need a fix to this problem and adding "window.size.ms" makes sense to me. Thanks for the KIP, Walker On Thu, Aug 20, 2020 at 2:22 PM Leah Thomas <ltho...@confluent.io> wrote: > Hi all, > > I'd like to start a discussion for KIP-659: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-659%3A+Improve+TimeWindowedDeserializer+and+TimeWindowedSerde+to+handle+window+size > > > The goal of the KIP is to ensure that window size is passed to the consumer > when needed, which will generally be for testing purposes, and to avoid > runtime errors when the *TimeWindowedSerde* is created without a window > size. > > Looking forward to hearing your feedback. > > Cheers, > Leah >
