Re: Kafka Stream Window

2021-10-25 Thread JING ZHANG
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, i

Kafka Stream Window

2021-10-25 Thread Mohammed Kamaal
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