docs: def reenqueue(self, batch):
          """Re-enqueue the given record batch in the accumulator to retry."""
          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)