Thanks for confirming that, Guozhang.
Regards,
Libo
-Original Message-
From: Guozhang Wang [mailto:wangg...@gmail.com]
Sent: Wednesday, December 18, 2013 4:34 PM
To: users@kafka.apache.org
Subject: Re: a consumer question
Jun is right. Just checked the code. If you set
t; Libo
> > >
> > >
> > > -Original Message-
> > > From: Jun Rao [mailto:jun...@gmail.com]
> > > Sent: Tuesday, December 17, 2013 12:40 AM
> > > To: users@kafka.apache.org
> > > Subject: Re: a consumer question
> > >
gt; > -Original Message-
> > From: Jun Rao [mailto:jun...@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
> > From: Jun Rao [mailto:jun...@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.
> &
a timeout exception, otherwise it
> returns true.
> Is that the right behavior?
>
> Regards,
>
> Libo
>
>
> -Original Message-
> From: Jun Rao [mailto:jun...@gmail.com]
> Sent: Tuesday, December 17, 2013 12:40 AM
> To: users@kafka.apache.org
> Subject: R
: 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 wrote:
> Hi folks,
>
> For this parameters, if consumer.t
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 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
