Question: Any idea on applying session window?

[praiwann]

I have some tasks which is required to windowing stream into session just like in Kafka Stream. You can find example from the following link. Any idea to achieve this?

https://kafka.apache.org/21/javadoc/org/apache/kafka/streams/kstream/SessionWindows.html

[elrik75]

As Faust is python code + Kafka/Rocksdb serialization. You can in theory build any function where the result is serializable. I've built my own windows because each of them has its own retention, aggregation, just saying it's flexible enough. I don't know KS SessionWindows but it looks similar to standard Faust windows, no ? https://faust.readthedocs.io/en/latest/userguide/tables.html#windowing