Description
Streams has windowed persistent stores (e.g., see PersistentKeyValueFactory interface with "windowed" method), however it does not allow for windowed in-memory stores (e.g., see InMemoryKeyValueFactory interface).
In addition to the interface not allowing it, streams does not actually have an implementation of an in-memory windowed store.
The implications are that operations that require windowing cannot use in-memory stores.
KIP-428: https://cwiki.apache.org/confluence/display/KAFKA/KIP-428%3A+Add+in-memory+window+store
Attachments
Issue Links
- blocks
-
KAFKA-6910 Ability to specify a default state store type or factory
-
- Resolved
-
-
KAFKA-7952 Consider to switch to in-memory stores in test whenever possible
-
- Open
-
-
KAFKA-4729 Stores for kstream-kstream join cannot be in-memory
-
- Resolved
-
- relates to
-
KAFKA-8029 Add in-memory bytes-only session store implementation
-
- Resolved
-
- links to