On Wed, Jan 4, 2017 at 11:54 PM, Vignesh <vignesh.v...@gmail.com> wrote:
> Hi, > > offsetsForTimes > <https://kafka.apache.org/0101/javadoc/org/apache/kafka/clients/consumer/ > KafkaConsumer.html#offsetsForTimes(java.util.Map)> > function > returns offset for a given timestamp. Does it use message's timestamp > (which could be LogAppendTime or set by user) or creation time of > logsegment file? > > This is actually tied to how the ListOffsetsRequest is handled. But if you're on a recent version, then the KIP https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=65868090 made it use the more accurate version based on message timestamps. > > KIP-33 > <https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 33+-+Add+a+time+based+log+index> > adds timestamp based index, and it is available only from 0.10.1 . Does > above function work on 0.10.0 ? If so, are there any differences in how it > works between versions 0.10.0 and 0.10.1 ? > > The KIP was only adopted and implemented in 0.10.1+. It is not available in 0.10.0. > Thanks, > Vignesh. >
