Hi,

Is there a way to define a sliding window with a count (number of
occurrence) of stream in Kafka Stream Window (KStream)?

In Flink we have,
stream.keyBy().countWindow(3,1) //where 3 is number/size of streams

Can you suggest an equivalent of the above in KStream

The below code takes only duration as both the arguments, is there a way to
pass number of occurrences here?
KStream.groupByKey().window(SlidingWindow(duration, duration))

Thanks

Reply via email to