Hey all, I'd like to open up the discussion on a KIP-734. This adds a new OffsetSpec to AdminClient.listOffsets so that we can easily determine the offset and timestamp of the message with the largest timestamp on a partition.
Please give it a look over and let me know what you think. https://cwiki.apache.org/confluence/display/KAFKA/KIP-734%3A+Improve+AdminClient.listOffsets+to+return+timestamp+and+offset+for+the+record+with+the+largest+timestamp Thanks Tom