code: def run(self):
          '''
          Set up and run
          '''
          self._setup_kafka()
          self._load_plugins()
          self._setup_stats()
          self._main_loop(f run(self):
          '''
          Set up and run
          '''
          self._setup_kafka()
          self._load_plugins()
          self._setup_stats()
          self._main_loop()
docs: Set up and run