Repository: kafka Updated Branches: refs/heads/trunk cdcbd9283 -> 9eabcc20d
MINOR: Updated KafkaZkClient.pathExists() to use ExistsRequest rather than using GetDataRequest Author: Mickael Maison <[email protected]> Reviewers: Ismael Juma <[email protected]> Closes #4217 from mimaison/pathExists Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9eabcc20 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/9eabcc20 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/9eabcc20 Branch: refs/heads/trunk Commit: 9eabcc20d2dc9529b64f3967222fdd30a65dc961 Parents: cdcbd92 Author: Mickael Maison <[email protected]> Authored: Thu Nov 16 01:41:50 2017 +0000 Committer: Ismael Juma <[email protected]> Committed: Thu Nov 16 01:41:50 2017 +0000 ---------------------------------------------------------------------- core/src/main/scala/kafka/zk/KafkaZkClient.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/9eabcc20/core/src/main/scala/kafka/zk/KafkaZkClient.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/zk/KafkaZkClient.scala b/core/src/main/scala/kafka/zk/KafkaZkClient.scala index a753c5b..24d7ba9 100644 --- a/core/src/main/scala/kafka/zk/KafkaZkClient.scala +++ b/core/src/main/scala/kafka/zk/KafkaZkClient.scala @@ -946,12 +946,12 @@ class KafkaZkClient(zooKeeperClient: ZooKeeperClient, isSecure: Boolean) extends } private[zk] def pathExists(path: String): Boolean = { - val getDataRequest = GetDataRequest(path) - val getDataResponse = retryRequestUntilConnected(getDataRequest) - getDataResponse.resultCode match { + val existsRequest = ExistsRequest(path) + val existsResponse = retryRequestUntilConnected(existsRequest) + existsResponse.resultCode match { case Code.OK => true case Code.NONODE => false - case _ => throw getDataResponse.resultException.get + case _ => throw existsResponse.resultException.get } }
