Fix memory leak when Broker.Open and Broker.Close called repeatedly
@@ -1367,6 +1367,7 @@ func (b *Broker) unregisterMetrics() {
for _, name := range b.registeredMetrics {
b.conf.MetricRegistry.Unregister(name)
}
+ b.registeredMetrics = nil
func (b *Broker) registerMeter(name string) metrics.Meter {