Yeah, I think we're miscommunicating. Suppression does not have a "grace period", it only has the "emit after" config.
The method `findAndVerifyWindowGrace` only extracts the exact specified grace period, as configured upstream. We pass the value we get back to `org.apache.kafka.streams.kstream.internals.suppress.SuppressedImpl#buildFinalResultsSuppression`, which then creates a `Suppressed` configuration using that time (the extracted grace period) as the "emit after" config, along with setting the `timeDefinition` to the window end time. Together these configs cause suppression to emit immediately right at the end of the grace period (as configured somewhere upstream). [ Full content available at: https://github.com/apache/kafka/pull/5567 ] This message was relayed via gitbox.apache.org for [email protected]
