You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2017/11/16 01:41:54 UTC
kafka git commit: MINOR: Updated KafkaZkClient.pathExists() to use
ExistsRequest
Repository: kafka
Updated Branches:
refs/heads/trunk cdcbd9283 -> 9eabcc20d
MINOR: Updated KafkaZkClient.pathExists() to use ExistsRequest
rather than using GetDataRequest
Author: Mickael Maison <mi...@gmail.com>
Reviewers: Ismael Juma <is...@juma.me.uk>
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 <mi...@gmail.com>
Authored: Thu Nov 16 01:41:50 2017 +0000
Committer: Ismael Juma <is...@juma.me.uk>
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
}
}