conduktor.io ↗

KIP-445 — In-memory Session Store

Accepted Kafka 2.3 Streams

Adds an in-memory `SessionStore` implementation to Kafka Streams via a new `Stores.inMemorySessionStore()` factory method. The session store type previously lacked an in-memory variant, forcing all session-windowed aggregations to use RocksDB even for workloads that fit in heap and do not need persistence.

Details

AuthorA. Sophie Blee-Goldman
StatusAccepted
Kafka Version2.3
JIRAKAFKA-8029
WikiView on Apache Wiki
Created2019-03-29
Last Modified2019-04-26
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.