Joe, Yes, this is a bit confusing. We have 2 offset related requests. One is OffsetFetchRequest and another is OffsetRequest. The former is used to get the offset within a consumer group and the latter is to get the offset before a particular timestamp. And there is of course the FetchRequest, which fetches messages on a given offset.
Thanks, Jun On Tue, Jan 7, 2014 at 9:00 AM, Joe Stein <joe.st...@stealth.ly> wrote: > 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 > > >
