如何增加动物园管理员连接超时

Question

我的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)

Answer 1

您有 2 个属性。

zookeeper.session.timeout.ms如果消费者在这段时间内未能向动物园管理员心跳，则认为它已死亡，并且将发生重新平衡

zookeeper.connection.timeout.ms客户端在与动物园管理员建立连接时等待的最长时间