private String logPrefix() {
        return String.format("stream-thread [%s]", Thread.currentThread().getName());
    }
Get or create the directory for the global stores.
@return directory for the global stores
@throws ProcessorStateException if the global store directory does not exists and could not be created
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java