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