kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Yu, Libo " <libo...@citi.com>
Subject RE: a consumer question
Date Wed, 18 Dec 2013 21:22:07 GMT
Thanks, Jun. That is also my guess:) If the exception is caught, I can easily
convert hasNext() from blocking to nonblocking.

Regards,

Libo


-----Original Message-----
From: Jun Rao [mailto:junrao@gmail.com] 
Sent: Wednesday, December 18, 2013 12:09 AM
To: users@kafka.apache.org
Subject: Re: a consumer question

Actually, hasNext() only returns false when the consumer connector is shutdown. Typically,
you either set consumer.timeout.ms to -1 or a value larger than 0. If it's set to 0, my guess
is that it throws a timeout exception immediately if there is no more message.

Thanks,

Jun


On Tue, Dec 17, 2013 at 4:57 PM, Guozhang Wang <wangguoz@gmail.com> wrote:

> If there is no more messages, hasNext will return false instead of 
> throwing an exception.
>
> Guozhang
>
>
> On Tue, Dec 17, 2013 at 11:53 AM, Yu, Libo <libo.yu@citi.com> wrote:
>
> > Sorry, a typo. Correct my question. When consumer.timeout.ms is set 
> > to
> 0,
> >  if there is no
> > message available, hasNext() throws a timeout exception, otherwise 
> > it returns true.
> > Is that the right behavior?
> >
> > Regards,
> >
> > Libo
> >
> >
> > -----Original Message-----
> > From: Jun Rao [mailto:junrao@gmail.com]
> > Sent: Tuesday, December 17, 2013 12:40 AM
> > To: users@kafka.apache.org
> > Subject: Re: a consumer question
> >
> > If there is a message, hasNext() returns true, not throwing an exception.
> >
> > Thanks,
> >
> > Jun
> >
> >
> > On Mon, Dec 16, 2013 at 11:29 AM, Yu, Libo <libo.yu@citi.com> wrote:
> >
> > > Hi folks,
> > >
> > > For this parameters, if consumer.timeout.ms is set to 0, whenever 
> > > I call ConsumerIterator's hasNext(), if there is a message 
> > > available, a timeout exception will be thrown. Is my understanding correct?
Thanks.
> > >
> > > consumer.timeout.ms
> > >
> > > -1
> > >
> > > Throw a timeout exception to the consumer if no message is 
> > > available for consumption after the specified interval
> > >
> > >
> > >
> > > Regards,
> > >
> > > Libo
> > >
> > >
> >
>
>
>
> --
> -- Guozhang
>

Mime
View raw message