diff options
| author | Kishore Nallan <kishore.nc@gmail.com> | 2018-08-31 19:12:44 +0530 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-08-31 06:42:44 -0700 |
| commit | 506822906e20b713d1d06b8a3e9b10bb04d803dc (patch) | |
| tree | 7ec66f76f8d92340591975dc68a0f652dafcf5bf | |
| parent | 5a04bc78f3392038733d65fc1e4830c8b14cd6fd (diff) | |
| download | kafka-python-506822906e20b713d1d06b8a3e9b10bb04d803dc.tar.gz | |
Clear the metrics dictionary on close. (#1569)
| -rw-r--r-- | kafka/metrics/metrics.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/metrics/metrics.py b/kafka/metrics/metrics.py index e9c465d..f2e99ed 100644 --- a/kafka/metrics/metrics.py +++ b/kafka/metrics/metrics.py @@ -257,3 +257,5 @@ class Metrics(object): """Close this metrics repository.""" for reporter in self._reporters: reporter.close() + + self._metrics.clear() |