From 41e1c13a52082521b3702a8466f6b8a484cc6ddf Mon Sep 17 00:00:00 2001 From: Kengo Seki Date: Thu, 4 Jul 2019 17:00:26 +0900 Subject: [PATCH] MINOR: Fix a wrong description in PipeDemo's javadoc (#6901) This PR fixes a wrong input stream name in PipeDemo's javadoc. Reviewers: Kamal Chandraprakash , Jason Gustafson --- .../java/org/apache/kafka/streams/examples/pipe/PipeDemo.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java b/streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java index 99505fd08ce..860f2ffa7f9 100644 --- a/streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java +++ b/streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java @@ -29,7 +29,7 @@ import java.util.concurrent.CountDownLatch; * Demonstrates, using the high-level KStream DSL, how to read data from a source (input) topic and how to * write data to a sink (output) topic. * - * In this example, we implement a simple "pipe" program that reads from a source topic "streams-file-input" + * In this example, we implement a simple "pipe" program that reads from a source topic "streams-plaintext-input" * and writes the data as-is (i.e. unmodified) into a sink topic "streams-pipe-output". * * Before running this example you must create the input topic and the output topic (e.g. via