conduktor.io ↗

KIP-65 — Expose timestamps to Connect

Accepted Kafka 1.0 Connect

KIP-65 propagates Kafka record timestamps (added in KIP-32) through the Connect framework by exposing them on `SourceRecord` and `SinkRecord`. Connect used its own record wrapper that omitted timestamps, so source connectors could not set record timestamps and sink connectors could not inspect them for time-based processing.

Details

AuthorShikhar Bhushan
StatusAccepted
Kafka Version1.0
JIRAKAFKA-3846
WikiView on Apache Wiki
Created2016-06-23
Last Modified2016-11-07
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.