class MsgKafka(MsgBase):
- def __init__(self, logger_name='msg'):
- self.logger = logging.getLogger(logger_name)
+ def __init__(self, logger_name='msg', lock=False):
+ super().__init__(logger_name, lock)
self.host = None
self.port = None
self.consumer = None