.groupByKey()
.count(Materialized.as(storeSupplier))
.toStream()
- .map((word, count) -> new KeyValue<>(word, WordCount.of(word, count)))
+ .map((word, counter) -> new KeyValue<>(word, WordCounter.of(word, counter)))
.to(outputTopic);
Topology topology = builder.build();