From dcdc8701d82a94c220e1a32adab4728b0df3b95e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Pawe=C5=82=20=C5=81ozi=C5=84ski?= <pawel.lozinski@gmail.com>
Date: Sat, 22 Feb 2020 22:54:04 +0100
Subject: [PATCH] Close ZK before canceling future with exception (#6228)

---
 .../apache/pulsar/zookeeper/ZookeeperBkClientFactoryImpl.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZookeeperBkClientFactoryImpl.java b/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZookeeperBkClientFactoryImpl.java
index aac96ce84c5c1..8cd674d580dfe 100644
--- a/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZookeeperBkClientFactoryImpl.java
+++ b/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZookeeperBkClientFactoryImpl.java
@@ -55,6 +55,7 @@ public CompletableFuture<ZooKeeper> create(String serverList, SessionType sessio
                         .build();
 
                 if (zk.getState() == States.CONNECTEDREADONLY && sessionType != SessionType.AllowReadOnly) {
+                    zk.close();
                     future.completeExceptionally(new IllegalStateException("Cannot use a read-only session"));
                 }