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