[KAFKA-4730] Streams does not have an in-memory windowed store

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.2.0
• Fix Version/s: 2.3.0
• Component/s: streams
• Labels: kip
• Assignee: Sophie Blee-Goldman
• Reporter: Eno Thereska
• Created: 03/Feb/17 10:19
• Updated: 02/Mar/19 01:25
• Resolved: 21/Feb/19 03:10

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

 

Issue Links

• blocks: KAFKA-6910 Ability to specify a default state store type or factory
• blocks: KAFKA-7952 Consider to switch to in-memory stores in test whenever possible
• blocks: KAFKA-4729 Stores for kstream-kstream join cannot be in-memory
• relates to: KAFKA-8029 Add in-memory bytes-only session store implementation
• links to: GitHub Pull Request #6239