.noTypeInfo(),
new JsonSerde<>(Word.class)
.noTypeInfo()))
- .count(Materialized
- .<Word,Long>as(storeSupplier)
- .withKeySerde(
- new JsonSerde<>(Word.class)
- .forKeys()
- .noTypeInfo())
- .withValueSerde(
- Serdes.Long()))
+ .count(Materialized.as(storeSupplier))
.toStream()
.map((word, count) -> new KeyValue<>(word, WordCount.of(word.getUser(), word.getWord(), count)))
.to(