diff --git a/kafka/metrics/metrics.py b/kafka/metrics/metrics.py index e9c465deb..f2e99edc9 100644 --- a/kafka/metrics/metrics.py +++ b/kafka/metrics/metrics.py @@ -257,3 +257,5 @@ def close(self): """Close this metrics repository.""" for reporter in self._reporters: reporter.close() + + self._metrics.clear()