kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From harikiran <harihawk...@gmail.com>
Subject Re: Detecting lost connection in high level consumer
Date Thu, 05 Feb 2015 00:07:22 GMT
Hey! Did anyone get a chance to read this?

Thanks!!
On Wed, Jan 28, 2015 at 6:21 PM harikiran <harihawking@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
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message