Thanks Guozhang and Jun for your replies. On Wed, Feb 4, 2015 at 4:06 PM, harikiran <harihawk...@gmail.com> wrote:
> Hey! Did anyone get a chance to read this? > > Thanks!! > > On Mon, Jan 19, 2015 at 1:26 AM harikiran <harihawk...@gmail.com> 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 hasNext() method on it. >> >> Irrespective of whether kafka broker was shutdown or there was no message >> written to kafka, I see a ConsumerTimeOut exception after 5000ms. >> >> My goal is to detect lost connection and reconnect but I cannot figure >> out a way. >> >> Any kind of help is appreciated. >> >> Thanks >> Hari >> >
