Hi, I aggregate some data with `aggregateByKey` and a `TimeWindows`.
I set the maintain duration of the window to 30 days. If it consumes a message older than 30 days, then a new aggregate is created for this old window. The problem is that this old windowed aggregate is of course incomplete and will overwrite a record in the final database. So is there a way to dismiss these old messages ? I only see the point of accepting old messages when the topology is launched in "repair" mode. By the way, is there any article about replaying old messages. Some tips and tricks, like "you'd better do that in another deployment of your topology", and/or "you'd better use topics dedicated to repair". Thanks Nicolas
