Repository: kafka Updated Branches: refs/heads/trunk e9426291a -> 9a7032720
MINOR: Clarify misleading comment in WordCount example Author: Gwen Shapira <[email protected]> Reviewers: Matthias J. Sax, Guozhang Wang Closes #2400 from gwenshap/wordcount-comment Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9a703272 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/9a703272 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/9a703272 Branch: refs/heads/trunk Commit: 9a7032720f4600099b130a0bb7b578cedc83e5ff Parents: e942629 Author: Gwen Shapira <[email protected]> Authored: Wed Jan 25 18:00:14 2017 -0800 Committer: Guozhang Wang <[email protected]> Committed: Wed Jan 25 18:00:14 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/9a703272/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();
