def reenqueue(self, batch, now=None):
        """
        Re-enqueue the given record batch in the accumulator. In Sender._complete_batch method, we check
        whether the batch has reached delivery_timeout_ms or not. Hence we do not do the delivery timeout check here.
        """
        batch.retry(now=now)
        with self._tp_lock(batch.topic_partition):
            dq = self._batches[batch.topic_partition]
            dq.appendleft(batch)

        Re-enqueue the given record batch in the accumulator. In Sender._complete_batch method, we check
        whether the batch has reached delivery_timeout_ms or not. Hence we do not do the delivery timeout check here.
        
kafka/producer/record_accumulator.py