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
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