You can use the offset request (kafka.api.OffsetRequest) with the given timestamp to get the offset whose message is published before the timestamp. Note that it is coarsen grained that the message returned maybe at worst one log file segment earlier than the timestamp.
On Sat, Feb 28, 2015 at 9:07 PM, sunil kalva <sambarc...@gmail.com> wrote: > Can i do a offset reset based on time not by message id, since most of > times we know when the processing engine failed (based on time), so it is > easy to reset the offset to that time for reprocessing. > > -- > SunilKalva > -- -- Guozhang
