[kafka] branch trunk updated: fix compile error for example (#6526)

[bb...@apache.org]

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 acb5188  fix compile error for example (#6526)
acb5188 is described below

commit acb5188810320224713babbd03eb3709f6e7968e
Author: Jarrod Urban <ja...@hivemindtechnologies.com>
AuthorDate: Mon Apr 1 17:39:05 2019 +0200

    fix compile error for example (#6526)
    
    Reviewers: Prashant Sabnekar, Bill Bejeck <bb...@gmail.com>
---
 docs/streams/index.html | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/docs/streams/index.html b/docs/streams/index.html
index 193a7b2..6872297 100644
--- a/docs/streams/index.html
+++ b/docs/streams/index.html
@@ -275,7 +275,7 @@ object WordCountApplication extends App {
   val wordCounts: KTable[String, Long] = textLines
     .flatMapValues(textLine => textLine.toLowerCase.split("\\W+"))
     .groupBy((_, word) => word)
-    .count(Materialized.as("counts-store"))
+    .count()(Materialized.as("counts-store"))
   wordCounts.toStream.to("WordsWithCountsTopic")
 
   val streams: KafkaStreams = new KafkaStreams(builder.build(), props)