Hi, I guess you would get suggestions more quickly if you send this email in user mail list of KStream.😀 Or you could use Flink to complete your requirements directly.
Mohammed Kamaal <mohammed.kamaa...@gmail.com> 于2021年10月25日周一 下午3:47写道： > 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 >
