Thanks Guozhang and Jun for your replies.
On Wed, Feb 4, 2015 at 4:07 PM, harikiran wrote:
> Hey! Did anyone get a chance to read this?
>
> Thanks!!
> On Wed, Jan 28, 2015 at 6:21 PM harikiran wrote:
>
>>
>> Hi
>>
>> I am using the 0811 Kafka High level consumer and I have configured "
>> consu
Hey! Did anyone get a chance to read this?
Thanks!!
On Wed, Jan 28, 2015 at 6:21 PM harikiran wrote:
>
> Hi
>
> I am using the 0811 Kafka High level consumer and I have configured "
> consumer.timeout.ms" to a value that is not -1, say 5000ms.
>
> I create the consumer iterator and invoke hasNex
That's actually how consumer.timeout.ms works. The iterator only gets an
exception is there is no message after the timeout. The error handling of
the connection is done in the consumer client library for you.
Thanks,
Jun
On Wed, Jan 28, 2015 at 6:21 PM, harikiran wrote:
> Hi
>
> I am using th
Hi
I am using the 0811 Kafka High level consumer and I have configured "
consumer.timeout.ms" to a value that is not -1, say 5000ms.
I create the consumer iterator and invoke hasNext() method on it.
Irrespective of whether kafka broker was shutdown or there was no message
written to kafka, I see
