public String takeNextOfflineLogDir() throws InterruptedException {
        return inner.takeNextOfflineLogDir();
    }
PartitionLogDirFailureChannel will ignore the failed dir and only fail the partition.
core/src/main/scala/kafka/log/streamaspect/PartitionLogDirFailureChannel.java