code: def run(self):
          
          if KSER_METRICS_ENABLED == "yes":
              from prometheus_client import start_http_server
              logger.info("Metric.Starting...")
              start_http_server(
                  os.getenv("KSER_METRICS_PORT", 8888),
                  os.getenv("KSER_METRICS_ADDRESS", "0.0.0.0")
              )
  
          logger.info("{}.Starting...".format(self.__class__.__name__))
  
          while True:
              if self.is_active() is True:
                  msg = next(self.client)
                  data = msg.value.decode('utf-8')
                  if self.client.config['enable_auto_commit'] is False:
                      self.client.commit()
                      logger.debug("{}: Manual commit done.".format(
                          self.__class__.__name__
                      ))
                  self.REGISTRY.run(data)
              else:
                  logger.warning("Consumer is paused")
                  time.sleep(60)
docs: Run consumer