Is that because you have no more data produced to the topic/partition after the last offset returned by OffsetRequest.LatestTime() ?
On Wed, Jun 18, 2014 at 6:19 AM, rafeeq s <rafeeq.ec...@gmail.com> wrote: > Simple Consumer is *not processing* messages when it's offset in > kafka.api.OffsetRequest.*LatestTime()* . > > If i use *EarlierTime() *offset method it is processing from start, which > is as expected. > > But when I try for *LatestTime()* offset, no reaction from simple consumer > and I am referring below simpleconsumer example: > > > https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example > > > Regards, > Rafeeq S > *(“What you do is what matters, not what you think or say or plan.” )* >
