conduktor.io ↗

KIP-32 — Add timestamps to Kafka message

Accepted Kafka 1.0 BrokerProtocol

Adds a per-message timestamp field to the Kafka message format (both CreateTime and LogAppendTime modes), enabling log retention and rolling to be driven by message timestamps rather than file modification times. File modification time was unreliable after replica reassignment (timestamps reset to current time) and insufficient for streaming processing use cases that require event-time semantics.

Protocol Impact

Produce · Fetch

Details

AuthorJiangjie Qin
StatusAccepted
Kafka Version1.0
JIRAKAFKA-2511
WikiView on Apache Wiki
Created2015-09-09
Last Modified2019-05-23
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.