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: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. Thanks, Jun On Mon, Dec 16, 2013 at 11:29 AM, Yu, Libo <libo...@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 > >
