private String getNamedTopologyDirName(final String topologyName) {
        return "__" + topologyName + "__";
    }
Get or create the directory for the provided {@link TaskId}.
@return directory for the {@link TaskId}
@throws ProcessorStateException if the task directory does not exist and could not be created
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java