fix compile error for example
Reviewers: Prashant Sabnekar, Bill Bejeck
@@ -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)
