Hello, *[Not sure if my email went through as I was not subscribed to this mailing list. Here is my original email]*
I found that there are two ways to send only the final result of a windowed groupBy, either using Suppressed <https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/kstream/KTable.html#suppress(org.apache.kafka.streams.kstream.Suppressed)>.untilWindowCloses on the final KTable or EmitStrategy <https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/kstream/TimeWindowedKStream.html#emitStrategy(org.apache.kafka.streams.kstream.EmitStrategy)> on the windowed stream. I tried to compare both but didn't find differences in the result they give. Are there any differences apart from the moment they are defined within the pipeline. And is there any preference on using one or the other ? Thanks, Ayoub Le ven. 12 avr. 2024 à 11:50, Ayoub <ayoubomar...@gmail.com> a écrit : > Hello, > > I found that there are two ways to send only the final result of a > windowed groupBy, either using Suppressed > <https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/kstream/KTable.html#suppress(org.apache.kafka.streams.kstream.Suppressed)>.untilWindowCloses > on the final KTable or EmitStrategy > <https://kafka.apache.org/37/javadoc/org/apache/kafka/streams/kstream/TimeWindowedKStream.html#emitStrategy(org.apache.kafka.streams.kstream.EmitStrategy)> > on > the windowed stream. > > I tried to compare both but didn't find differences in the result they > give. > > Are there any differences apart from the moment they are defined within > the pipeline. And Is there any preference on using one or the other ? > > Thanks, > Ayoub >
