public void close() {
        close(Long.MAX_VALUE, false);
    }
Shutdown this {@code KafkaStreams} instance by signaling all the threads to stop, and then wait for them to join.
This will block until all threads have stopped.
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java