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,

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

Reply via email to