Repository: kafka Updated Branches: refs/heads/0.10.2 47154d804 -> d54855a48
MINOR: Clarify misleading comment in WordCount example Author: Gwen Shapira <csh...@gmail.com> Reviewers: Matthias J. Sax, Guozhang Wang Closes #2400 from gwenshap/wordcount-comment (cherry picked from commit 9a7032720f4600099b130a0bb7b578cedc83e5ff) Signed-off-by: Guozhang Wang <wangg...@gmail.com> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d54855a4 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/d54855a4 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/d54855a4 Branch: refs/heads/0.10.2 Commit: d54855a481da9b98d5abc413f57927d0bc2546d2 Parents: 47154d8 Author: Gwen Shapira <csh...@gmail.com> Authored: Wed Jan 25 18:00:14 2017 -0800 Committer: Guozhang Wang <wangg...@gmail.com> Committed: Wed Jan 25 18:00:21 2017 -0800 ---------------------------------------------------------------------- .../org/apache/kafka/streams/examples/wordcount/WordCountDemo.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/d54855a4/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java ---------------------------------------------------------------------- diff --git a/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java b/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java index 99fbc15..b1d3c52 100644 --- a/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java +++ b/streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java @@ -53,6 +53,8 @@ public class WordCountDemo { props.put(StreamsConfig.VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName()); // setting offset reset to earliest so that we can re-run the demo code with the same pre-loaded data + // Note: To re-run the demo, you need to use the offset reset tool: + // https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Streams+Application+Reset+Tool props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); KStreamBuilder builder = new KStreamBuilder();
