Mar 30, 2021
Hi Stephane,
Quite illustrative and also up to the point. Did you try to use the suppress() for this last step regarding the aggregation over 90 days? May be at the time that you wrote this article this wasn't in place.
https://www.confluent.io/blog/kafka-streams-take-on-watermarks-and-triggers/