如何增加zookeeper连接超时答案

【问题标题】：How to increase zookeeper connection timeout如何增加zookeeper连接超时
【发布时间】：2016-05-08 19:47:58
【问题描述】：

我的Kafka 消费者经常失去与Zookeeper 的连接，并且由于连接超时而无法连接。

如何解决这个问题？

谢谢。以下是日志。

Exception in thread "main" org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server within timeout: 4000
at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:1223)
at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:155)
at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:129)
at kafka.utils.ZkUtils$.createZkClientAndConnection(ZkUtils.scala:89)
at kafka.utils.ZkUtils$.apply(ZkUtils.scala:71)
at kafka.consumer.ZookeeperConsumerConnector.connectZk(ZookeeperConsumerConnector.scala:181)
at kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:129)
at kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:65)
at kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:68)
at kafka.consumer.Consumer$.createJavaConsumerConnector(ConsumerConnector.scala:120)
at kafka.consumer.Consumer.createJavaConsumerConnector(ConsumerConnector.scala)
at com.steelwedge.consumer.JobConsumer.<init>(JobConsumer.java:53)

【问题讨论】：

标签： apache-zookeeper kafka-consumer-api

【解决方案1】：

您有 2 个属性。

zookeeper.session.timeout.ms 如果消费者在这段时间内没有向zookeeper发送心跳，则认为它已经死亡，并且会发生重新平衡

zookeeper.connection.timeout.ms 客户端与 zookeeper 建立连接时等待的最长时间

【讨论】：