| commit | 4d6c15114b9b6a0fc41b58993cf8acdd0e617b2f | [log] [tgz] |
|---|---|---|
| author | XuanYang-cn <xuan.yang@zilliz.com> | Fri Mar 26 23:48:08 2021 +0800 |
| committer | GitHub <noreply@github.com> | Fri Mar 26 08:48:08 2021 -0700 |
| tree | d79d78411ab00ac25dc799cc5828785361ea03c2 | |
| parent | 5fb7f55939e6f4ec28126339b22a6b4018c0f2fa [diff] |
Close cnxPool when closing a Client (#494)
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) Close() { c.handlers.Close() + c.cnxPool.Close() } func (c *client) namespaceTopics(namespace string) ([]string, error) {