@Override
            public void run() {
                streams.close();
                latch.countDown();
            }
In this example, we implement a simple LineSplit 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;
the code split each text line in string into words and then write back into a sink topic "streams-linesplit-output" where
each record represents a single word.
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/LineSplit.java