----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/14582/ -----------------------------------------------------------
Review request for kafka. Repository: kafka Description ------- Upgrading zkclient to verion 0.4. Adds retry logic in case of a failed ZooKeeper session re-establishment. Diffs ----- core/build.sbt b5bcb44f783ae6fe2cfdc091e53e867a56a1e592 core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala 77449f53dc7a8aef14b29790ee6ac62cbafadda7 core/src/main/scala/kafka/consumer/ZookeeperTopicEventWatcher.scala a67c193df9f7cbfc52f75dc1b71dc017de1b5fe2 core/src/main/scala/kafka/controller/KafkaController.scala 88d130f55997b72a8590e4cfe92857a7320e70d5 core/src/main/scala/kafka/server/KafkaHealthcheck.scala 84ea17a068c84592d3d0b007982f7be8fbc231b7 core/src/main/scala/kafka/server/KafkaServer.scala c148fdff61b13c2f06d8d048365daee30a286842 core/src/main/scala/kafka/utils/ZkReconnector.scala PRE-CREATION core/src/main/scala/kafka/utils/ZkUtils.scala d1c4b3d7b3d11c88a1d1474aadbb727704cfb759 core/src/test/scala/unit/kafka/zk/ZkReconnecterTest.scala PRE-CREATION Diff: https://reviews.apache.org/r/14582/diff/ Testing ------- Thanks, Anatoly Fayngelerin