- .groupByKey(Grouped.with(
- new JsonSerde<>(Word.class)
- .forKeys()
- .noTypeInfo(),
- new JsonSerde<>(Word.class)
- .noTypeInfo()))
- .count(Materialized
- .<Word,Long>as(storeSupplier)
- .withKeySerde(
- new JsonSerde<>(Word.class)
- .forKeys()
- .noTypeInfo())
- .withValueSerde(
- Serdes.Long()))
+ .groupByKey()
+ .count(
+ Materialized
+ .<Word, Long>as(storeSupplier)
+ .withKeySerde(new JsonSerde<>().copyWithType(Word.class).forKeys()))