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
