public String takeNextOfflineLogDir() throws InterruptedException {
        return offlineLogDirQueue.take();
    }
Get the next offline log dir from logDirFailureEvent queue.
The method will wait if necessary until a new offline log directory becomes available

@return The next offline log dir.
@throws InterruptedException
storage/src/main/java/org/apache/kafka/storage/internals/log/LogDirFailureChannel.java