conduktor.io ↗

KIP-79 — ListOffsetRequest/ListOffsetResponse v1 and add timestamp search methods to the new consumer

Accepted Kafka 1.0 ConsumerProtocol

KIP-79 introduces `ListOffsetRequest` v1, which returns a single offset (not an array) for each requested partition and supports accurate timestamp-based offset lookup using the per-message timestamps introduced by KIP-33. It also adds `Consumer.offsetsForTimes()` and `Consumer.endOffsets()` to the high-level consumer API so applications can rewind consumption to a specific point in time without using the low-level `SimpleConsumer`.

Details

AuthorJiangjie Qin
StatusAccepted
Kafka Version1.0
JIRAKAFKA-4148
WikiView on Apache Wiki
Created2016-08-30
Last Modified2016-09-29
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.