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<Long> 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<String, String> textLines = builder.stream("streams-plaintext-input", - Consumed.with(stringSerde, stringSerde); +KStream<String, String> textLines = builder.stream( + "streams-plaintext-input", + Consumed.with(stringSerde, stringSerde) + ); KTable<String, Long> wordCounts = textLines // Split each text line, by whitespace, into words. @@ -67,7 +69,7 @@ KTable<String, Long> 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()));