code: def maybe_resume_consumer(self):
          
          # If we have been paused by flow control, check and see if we are
          # back within our limits.
          #
          # In order to not thrash too much, require us to have passed below
          # the resume threshold (80% by default) of each flow control setting
          # before restarting.
          if self._consumer is None or not self._consumer.is_paused:
              return
  
          if self.load < self.flow_control.resume_threshold:
              self._consumer.resume()
          else:
              _LOGGER.debug("Did not resume, current load is %s", self.load)
docs: Check the current load and resume the consumer if needed.