Thanks Guozhang and Jun for your replies. On Wed, Feb 4, 2015 at 4:07 PM, harikiran <harihawk...@gmail.com> wrote:
> Hey! Did anyone get a chance to read this? > > Thanks!! > On Wed, Jan 28, 2015 at 6:21 PM 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 >> >>
