In my streaming topology, I am using the suppress dsl operator. As per the documentation, it is supposed to output the final results after the window closes. But I noticed it's not emitting anything at all. Here is the pseudo code of my topology.
.filter((key, value) -> ...) .flatMap((key, value) -> { ... }) .groupByKey(Grouped.with(Serdes.String(), ...)) .windowedBy(TimeWindows.of(Duration.ofMinutes(1)).grace(Duration.ofMinutes(1))) .aggregate( ... ).suppress(Suppressed.untilWindowCloses(Suppressed.BufferConfig.unbounded())); Anything wrong here?? Thanks Thameem