kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alexis Midon <alexis.mi...@airbnb.com.INVALID>
Subject Re: Enable Kafka Consumer Reconnect to Zookeeper
Date Wed, 17 Feb 2016 09:30:21 GMT
By "re-connect", I'm assuming that the ZK session is expired, not
For details see

In that case, the high level consumer is basically dead, and the
application should create a new instance of it.

On Mon, Feb 15, 2016 at 12:22 PM Joe San <codeintheopen@gmail.com> wrote:

> Any ideas as to which property should I set to enable Zookeeper
> re-connection? I have the following properties defined for my consumer
> (High Level Consumer API). Is this enough for a automatic Zookeeper
> re-connect?
> val props = new Properties()
> props.put("zookeeper.connect", zookeeper)
> props.put("group.id", groupId)
> props.put("auto.commit.enabled", "false")
> // this timeout is needed so that we do not block on the stream!
> props.put("consumer.timeout.ms", "1")
> props.put("zookeeper.sync.time.ms", "200")

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