Description
Currently, when querying state store, it is not clear when the key was updated last. The ides of this JIRA is to make the latest update timestamp for each key-value-pair of the state store accessible.
For example, this might be useful to
- check if a value was update but did not changed (just compare the update TS)
- if you want to consider only recently updated keys
Covered via KIP-258: https://cwiki.apache.org/confluence/display/KAFKA/KIP-258%3A+Allow+to+Store+Record+Timestamps+in+RocksDB
Attachments
Issue Links
- Is contained by
-
KAFKA-3522 Consider adding version information into rocksDB storage format
- Resolved
-
KAFKA-6521 Store record timestamps in KTable stores
- Resolved