hmmm, that should be the "offset to fetch from", not sure why the variable is called "time" =8^/ unless I am looking at something else from what you are asking but this I think (another dev please confirm or explain why it is time).
case class PartitionOffsetRequestInfo(time: Long, maxNumOffsets: Int) should be case class PartitionOffsetRequestInfo(offsetToFetchFrom: Long, maxNumOffsets: Int) which matches the Fetch API we have documented https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol /******************************************* Joe Stein Founder, Principal Consultant Big Data Open Source Security LLC http://www.stealth.ly Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> ********************************************/ On Tue, Jan 7, 2014 at 11:31 AM, Calvin Lei <ckp...@gmail.com> wrote: > Does it support an long timestamp? Tried it and the resulting offset > response contains an empty long array. > > > > > > -- > Sent from Gmail Mobile >
