You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by rafeeq s <ra...@gmail.com> on 2014/06/18 15:19:34 UTC

SimpleConsumer kafka.api.OffsetRequest.LatestTime() not working ?

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.” )*

Re: SimpleConsumer kafka.api.OffsetRequest.LatestTime() not working ?

Posted by rafeeq s <ra...@gmail.com>.

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 <su...@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 <ne...@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 <ra...@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: supun06@gmail.com;  Mobile: +1 812 369 6762
> Blog: http://supunk.blogspot.com
>

Re: SimpleConsumer kafka.api.OffsetRequest.LatestTime() not working ?

Posted by Supun Kamburugamuva <su...@gmail.com>.

Hi Refeeq,

I'm using the LatestTime() and it is working.

Thanks,
Supun..


On Wed, Jun 18, 2014 at 12:07 PM, Neha Narkhede <ne...@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 <ra...@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: supun06@gmail.com;  Mobile: +1 812 369 6762
Blog: http://supunk.blogspot.com

Re: SimpleConsumer kafka.api.OffsetRequest.LatestTime() not working ?

Posted by Neha Narkhede <ne...@gmail.com>.

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 <ra...@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.” )*
>