conduktor.io ↗

KIP-397 — Add methods to override fetch offsets based on timestamp

Discussion Consumer

Adds a `KafkaConsumer.seekToTimestamp(Map<TopicPartition, Long>)` convenience method that combines `offsetsForTimes` and `seek` into a single call. Currently, seeking to a timestamp requires constructing intermediate data structures across three separate API calls, which is verbose and error-prone.

Details

AuthorBrandon Kirchner
StatusDiscussion
WikiView on Apache Wiki
Created2018-11-29
Last Modified2018-11-29
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.