diff --git a/docs/quickstart.html b/docs/quickstart.html index 574d7461086..c8f01d49c51 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 WordCountDemo example code (converted to use Java 8 lambda expressions for easy reading).

-KTable 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
 

-Here, the first column is the Kafka message key, and the second column is the message value, both in in java.lang.String format. +Here, the first column is the Kafka message key, and the second column is the message value, both in java.lang.String 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.