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

Reply via email to