Thanks to all. LatestTime() is working as expected.
Regards, Rafeeq S *(“What you do is what matters, not what you think or say or plan.” )* On Wed, Jun 18, 2014 at 8:40 PM, Supun Kamburugamuva <supu...@gmail.com> wrote: > Hi Refeeq, > > I'm using the LatestTime() and it is working. > > Thanks, > Supun.. > > > On Wed, Jun 18, 2014 at 12:07 PM, Neha Narkhede <neha.narkh...@gmail.com> > wrote: > > > 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.” )* > > > > > > > > > -- > Supun Kamburugamuva > Member, Apache Software Foundation; http://www.apache.org > E-mail: supu...@gmail.com; Mobile: +1 812 369 6762 > Blog: http://supunk.blogspot.com >
