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
| Author | Lei Chen |
| Status | Discussion |
| JIRA | KAFKA-7325 |
| Wiki | View on Apache Wiki |
| Created | 2018-08-21 |
| Last Modified | 2018-08-23 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.