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 <jarrod.ur...@hivemindtechnologies.com> AuthorDate: Mon Apr 1 17:39:05 2019 +0200 fix compile error for example (#6526) Reviewers: Prashant Sabnekar, Bill Bejeck <bbej...@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)