conduktor.io ↗

KIP-428 — Add in-memory window store

Accepted Kafka 2.3 Streams

Adds an in-memory implementation of the windowed state store for Kafka Streams, available via Stores.inMemoryWindowStore(). Only a persistent (RocksDB-backed) windowed store existed, but some use cases — short retention windows, latency-sensitive stateful ops — benefit from keeping all state in heap memory without the serialization overhead of RocksDB.

Details

AuthorA. Sophie Blee-Goldman
StatusAccepted
Kafka Version2.3
JIRAKAFKA-4730
WikiView on Apache Wiki
Created2019-02-06
Last Modified2019-02-20
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.