public long getDeliveryTimeoutMs() {
        return deliveryTimeoutMs;
    }
Get a list of batches which have been sitting in the accumulator too long and need to be expired.
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java