@Override
            public void run() {
                streams.close();
                latch.countDown();
            }
In this example, we implement a simple Pipe 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,
and writes the messages as-is into a sink topic "streams-pipe-output".
streams/quickstart/java/src/main/resources/archetype-resources/src/main/java/Pipe.java