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

Reply via email to