@Override
            public void run() {
                streams.close();
                latch.countDown();
            }
In this example, we implement a simple WordCount program using the high-level Streams DSL
that reads from a source topic "streams-plaintext-input", where the values of messages represent lines of text,
split each text line into words and then compute the word occurrence histogram, write the continuous updated histogram
into a topic "streams-wordcount-output" where each record is an updated count of a single word.
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/WordCount.java