Kafka Stream aggregation how to get only aggregated result for a window

[lakitha_dias]

Hi, I am currently working on a task where it needs to group incoming events based on an identifier within a given time window.

Tumbling window mechanism used in this scenario and its correctly aggregating the results.

The problem is, I am seeing multiple intermediate aggregation results within the given time window, appreciate if someone can suggest a solution for this.

Below is the code section for the aggregation.

[lbrutschy]

Hey. You may be looking for suppression. See Suppressed (kafka 3.6.1 API)

[lakitha_dias]

Hi, thanks for the response. I have added the suppression configuration , looks the behavior is same as earlier, Other point to mention is, i am using the wall clock time in the consumer.

I have tried with the emit strategy options as well and ended up with the same result.

emitStrategy(EmitStrategy.onWindowClose())