code: def _commit_timer_failed(self, fail):
          
          log.warning(
              '_commit_timer_failed: uncaught error %r: %s in _auto_commit',
              fail, fail.getBriefTraceback())
          self._commit_looper_d = self._commit_looper.start(
              self.auto_commit_every_s, now=False)
docs: Handle an error in the commit() function
  
          Our commit() function called by the LoopingCall failed. Some error
          probably came back from Kafka and _check_error() raised the exception
          For now, just log the failure and restart the loop