This is an automated email from the ASF dual-hosted git repository.

bbejeck pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 342c336  MINOR: Missing punctuation marks in quickstart (#5755)
342c336 is described below

commit 342c336bf9706a99c65c7fd42b0f5edeccb8adbe
Author: Vito Jeng <vitoj...@users.noreply.github.com>
AuthorDate: Fri Feb 22 08:41:03 2019 +0800

    MINOR: Missing punctuation marks in quickstart (#5755)
    
    Minor fix for missing punctuation marks in the quickstart.
    
    Reviewers: John Roesler <j...@confluent.io>, Bill Bejeck <bbej...@gmail.com>
---
 docs/streams/quickstart.html | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/docs/streams/quickstart.html b/docs/streams/quickstart.html
index 9abeed4..717fe46 100644
--- a/docs/streams/quickstart.html
+++ b/docs/streams/quickstart.html
@@ -56,8 +56,10 @@ final Serde&lt;Long&gt; longSerde = Serdes.Long();
 // Construct a `KStream` from the input topic "streams-plaintext-input", where 
message values
 // represent lines of text (for the sake of this example, we ignore whatever 
may be stored
 // in the message keys).
-KStream&lt;String, String&gt; textLines = 
builder.stream("streams-plaintext-input",
-    Consumed.with(stringSerde, stringSerde);
+KStream&lt;String, String&gt; textLines = builder.stream(
+      "streams-plaintext-input",
+      Consumed.with(stringSerde, stringSerde)
+    );
 
 KTable&lt;String, Long&gt; wordCounts = textLines
     // Split each text line, by whitespace, into words.
@@ -67,7 +69,7 @@ KTable&lt;String, Long&gt; wordCounts = textLines
     .groupBy((key, value) -> value)
 
     // Count the occurrences of each word (message key).
-    .count()
+    .count();
 
 // Store the running counts as a changelog stream to the output topic.
 wordCounts.toStream().to("streams-wordcount-output", 
Produced.with(Serdes.String(), Serdes.Long()));

Reply via email to