public boolean await(long timeout, TimeUnit unit) throws InterruptedException {
        return latch.await(timeout, unit);
    }
Await the completion of this request (up to the given time interval)
@param timeout The maximum time to wait
@param unit The unit for the max time
@return true if the request completed, false if we timed out
clients/src/main/java/org/apache/kafka/clients/producer/internals/ProduceRequestResult.java