This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 4d6c151 Close cnxPool when closing a Client (#494)
4d6c151 is described below
commit 4d6c15114b9b6a0fc41b58993cf8acdd0e617b2f
Author: XuanYang-cn <xuan.y...@zilliz.com>
AuthorDate: Fri Mar 26 23:48:08 2021 +0800
Close cnxPool when closing a Client (#494)
---
pulsar/client_impl.go | 1 +
1 file changed, 1 insertion(+)
diff --git a/pulsar/client_impl.go b/pulsar/client_impl.go
index ee8ff50..8db3028 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) {
