Page History

...

with the seqnum (used for de-duping). So the eventual result is that when we deserialize, we do not assume the windowed changelog key has a seq_num, and the window extracted will be gibberish since the bytes won't be alligned.

The fix here is to introduce a new Serde in WindowSerdes that will handle explicitly, windowed changelog input topic. 

2) In the constructor of TimeWindowedDeserializer, the windowSize is fixed to Long.MAX_VALUE:

...