From 76d6905438527aebffb4abddf688e79364428a05 Mon Sep 17 00:00:00 2001
From: Baron Hou <houbaron@gmail.com>
Date: Mon, 17 May 2021 19:54:49 +0800
Subject: [PATCH] fix connections leak

---
 pulsar/client_impl.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pulsar/client_impl.go b/pulsar/client_impl.go
index c879d6f..7ce4a73 100644
--- a/pulsar/client_impl.go
+++ b/pulsar/client_impl.go
@@ -188,6 +188,7 @@ func (c *client) TopicPartitions(topic string) ([]string, error) {
 
 func (c *client) Close() {
 	c.handlers.Close()
+	c.cnxPool.Close()
 }
 
 func (c *client) namespaceTopics(namespace string) ([]string, error) {