Repository: kafka Updated Branches: refs/heads/0.10.2 4f6135931 -> f68c7e0f3
MINOR: Escape '<' and '>' symbols in quickstart streams code snippet This was missing from [an earlier PR](https://github.com/apache/kafka/pull/2247) that escaped these symbols in another section of the doc. Author: Vahid Hashemian <[email protected]> Reviewers: Ewen Cheslack-Postava <[email protected]> Closes #2453 from vahidhashemian/doc/escape_lt_gt_in_streams_code (cherry picked from commit 0c83eddcda8ed1b483a869f0915815204e3faade) Signed-off-by: Ewen Cheslack-Postava <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/f68c7e0f Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/f68c7e0f Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/f68c7e0f Branch: refs/heads/0.10.2 Commit: f68c7e0f3fa005ac1476a1593067a365fe58dd73 Parents: 4f61359 Author: Vahid Hashemian <[email protected]> Authored: Thu Jan 26 15:04:35 2017 -0800 Committer: Ewen Cheslack-Postava <[email protected]> Committed: Thu Jan 26 15:04:55 2017 -0800 ---------------------------------------------------------------------- docs/quickstart.html | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/f68c7e0f/docs/quickstart.html ---------------------------------------------------------------------- diff --git a/docs/quickstart.html b/docs/quickstart.html index 574d746..c8f01d4 100644 --- a/docs/quickstart.html +++ b/docs/quickstart.html @@ -282,7 +282,7 @@ This quickstart example will demonstrate how to run a streaming application code of the <code>WordCountDemo</code> example code (converted to use Java 8 lambda expressions for easy reading). </p> <pre> -KTable<String, Long> wordCounts = textLines +KTable<String, Long> wordCounts = textLines // Split each text line, by whitespace, into words. .flatMapValues(value -> Arrays.asList(value.toLowerCase().split("\\W+"))) @@ -389,7 +389,7 @@ summit 1 </pre> <p> -Here, the first column is the Kafka message key, and the second column is the message value, both in in <code>java.lang.String</code> format. +Here, the first column is the Kafka message key, and the second column is the message value, both in <code>java.lang.String</code> format. Note that the output is actually a continuous stream of updates, where each data record (i.e. each line in the original output above) is an updated count of a single word, aka record key such as "kafka". For multiple records with the same key, each later record is an update of the previous one. </p>
