As described in https://cwiki.apache.org/confluence/display/KAFKA/KIP-328%3A+Ability+to+suppress+updates+for+KTables
This ticket only covers the grace period portion of the work.
Improve processing of late records for window operations
KIP-328: Add in-memory Suppression
Rethink Unification of Caching with Dedupping
allow to attach callbacks in kafka streams, to be triggered when a window is expired
GitHub Pull Request #5369