def metric_change(self, metric):
        with self._lock:
            category = self.get_category(metric)
            if category not in self._store:
                self._store[category] = {}
            self._store[category][metric.metric_name.name] = metric
dataset/ETHPy150Open dpkp/kafka-python/kafka/metrics/dict_reporter.py/DictReporter.metric_change/original