docs: def on_startup_error(self, error):
          """Invoked when a pre-condition for starting the consumer has failed.
          Log the error and then exit the process.
  
          """
          LOGGER.critical('Could not start %s: %s', self.consumer_name, error)
          self.set_state(self.STATE_STOPPED)