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 > >
