public State state() {
        // we do not need to use the stat lock since the variable is volatile
        return state;
    }
@return The state this instance is in
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java