'Re-enqueue the given record batch in the accumulator to retry.'

def reenqueue(self, batch):

    now = time.time()
    batch.attempts += 1
    batch.last_attempt = now
    batch.last_append = now
    batch.set_retry()
    assert (batch.topic_partition in self._tp_locks), 'TopicPartition    not    in    locks    dict'
    assert (batch.topic_partition in self._batches), 'TopicPartition    not    in    batches'
    dq = self._batches[batch.topic_partition]
    with self._tp_locks[batch.topic_partition]:
        dq.appendleft(batch)
