Re: getOffsetsBefore and latest

2014-12-15 Thread Neha Narkhede
> > what about getOffsetsBefore using kafka.api.OffsetRequest.LatestTime? am i > safe to assume this returns me truly the most recent offset + 1 for each > partition? That's right. On Mon, Dec 15, 2014 at 7:18 AM, Koert Kuipers wrote: > > i read in several places that getOffsetsBefore does not

getOffsetsBefore and latest

2014-12-15 Thread Koert Kuipers
i read in several places that getOffsetsBefore does not necessary returns the last offset before the timestamp, because it is basically file based (so it works at the granularity of the files kafka produces). what about getOffsetsBefore using kafka.api.OffsetRequest.LatestTime? am i safe to assume