

def __init__(self, prefix=''):
    self._lock = threading.Lock()
    self._prefix = (prefix if prefix else '')
    self._store = {
        
    }

dataset/ETHPy150Open dpkp/kafka-python/kafka/metrics/dict_reporter.py DictReporter.__init__/original