KIP-94 — Session Windows

Accepted Streams

Adds session window support to Kafka Streams DSL via `KGroupedStream.windowedBy(SessionWindows.with(...))`, grouping records into variable-length windows that extend whenever a new record arrives within an inactivity gap. Fixed-size (tumbling/hopping) windows cannot model user activity sessions, which have no predetermined duration and are defined by gaps in activity rather than a fixed time interval.

Details