private void throwOnFatalException(final Exception fatalUserException,
                                           final TopicPartition topicPartition,
                                           final String storeName) {
            throw new StreamsException(
                    String.format("Fatal user code error in store restore listener for store %s, partition %s.",
                            storeName,
                            topicPartition),
                    fatalUserException);
        }
If all threads are up, including the global thread, set to RUNNING
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java