public void reenqueue(ProducerBatch batch, long now) {
        batch.reenqueued(now);
        Deque<ProducerBatch> deque = getOrCreateDeque(batch.topicPartition);
        synchronized (deque) {
            if (transactionManager != null)
                insertInSequenceOrder(deque, batch);
            else
                deque.addFirst(batch);
        }
    }
Re-enqueue the given record batch in the accumulator. In Sender.completeBatch method, we check
whether the batch has reached deliveryTimeoutMs or not. Hence we do not do the delivery timeout check here.
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java