[ https://issues.apache.org/jira/browse/KAFKA-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Konstantine Karantasis updated KAFKA-12541: ------------------------------------------- Fix Version/s: 3.0.0 > AdminClient.listOffsets should return the offset for the record with highest > timestamp > -------------------------------------------------------------------------------------- > > Key: KAFKA-12541 > URL: https://issues.apache.org/jira/browse/KAFKA-12541 > Project: Kafka > Issue Type: Improvement > Components: admin > Reporter: Tom Scott > Assignee: Tom Scott > Priority: Minor > Fix For: 3.0.0 > > > In Kafka 2.7 the following method was added to AdminClient that provides this > information: > {panel} > {panel} > |{{public}} {{ListOffsetsResult listOffsets(Map<TopicPartition,OffsetSpec> > topicPartitionOffsets,}} > {{ }}{{ListOffsetsOptions options)}}| > [https://kafka.apache.org/27/javadoc/org/apache/kafka/clients/admin/KafkaAdminClient.html#listOffsets-java.util.Map-org.apache.kafka.clients.admin.ListOffsetsOptions-] > where OffsetSpec can be: > * OffsetSpec.EarliestSpec > * OffsetSpec.LatestSpec > * OffsetSpec.TimestampSpec > > This ticket introduces a new spec: > {panel} > {panel} > |{{OffsetSpec.MaxTimestampSpec }}{{// this returns the offset and timestamp > for the record with the highest timestamp.}}| > This indicates to the AdminClient that we want to fetch the timestamp and > offset for the record with the largest timestamp produced to a partition. -- This message was sent by Atlassian Jira (v8.3.4#803005)