kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vignesh <vignesh.v...@gmail.com>
Subject Does offsetsForTimes use createtime of logsegment file?
Date Thu, 05 Jan 2017 07:54:51 GMT
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?


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 ?

Thanks,
Vignesh.

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message