Major Description
The key-value state stores used by Kafka Streams today maintain only the latest value associated with each key. In order to support applications which require access to older record versions, Kafka Streams should have versioned state stores. Versioned state stores are similar to key-value stores except they can store multiple record versions for a single key. An example use case for versioned key-value stores is in providing proper temporal join semantics for stream-tables joins with regards to out-of-order data.
See KIP for more: https://cwiki.apache.org/confluence/display/KAFKA/KIP-889%3A+Versioned+State+Stores
Attachments
Issue Links
- supercedes
-
KAFKA-10493 KTable out-of-order updates are not being ignored
-
- Resolved
-
- links to
(18 links to)