conduktor.io ↗

KIP-362 — Support dynamic gap session window

Discussion Streams

Adds a DynamicSessionWindows type to the Streams DSL, allowing the session gap to be computed per-record from a user-supplied SessionWindowMergeCallback rather than being a fixed global value. Real-world session semantics often depend on record content (e.g., user tier, event type), which is impossible to express with a fixed inactivity gap.

Details

AuthorLei Chen
StatusDiscussion
JIRAKAFKA-7325
WikiView on Apache Wiki
Created2018-08-21
Last Modified2018-08-23
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.