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