code: def _send_timer_failed(self, fail):
          
          log.warning('_send_timer_failed:%r: %s', fail,
                      fail.getBriefTraceback())
          self._sendLooperD = self._sendLooper.start(
              self.batch_every_t, now=False)
docs: Our _send_batch() 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