Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

Table of Contents

Status

Current state"Under Discussion"Accepted" [VOTE] KIP-258: Allow to Store Record Timestamps in RocksDB

Discussion thread[DISCUSS] KIP-258: Allow to Store Record Timestamps in RocksDB

JIRA

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-3522

Released: 1 2.2

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

In order to improve the provided stream processing semantics of – and to add new feature to – Kafka Streams, we want to be able to store record timestamps in KTables. This allows us to address multiple issues like

  • store timestampe timestamps in KTables (KAFKA-6521)
  • handling out-of-order data for source KTable (related to KAFKA-5533)
  • improve timestamp propagation for DSL operator (KAFKA-6455)
  • return the timestamp of the latest update in Interactive Queries (KAFKA-4304)
  • add TTL for KTables (KAFKA-4212 and KAFKA-4273)

...