> > 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 <ko...@tresata.com> wrote: > > 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 this returns me truly the most recent offset + 1 for each > partition? > > thanks! koert > -- Thanks, Neha
