- .stream(usersInputTopic)
- .toTable(Materialized.with(null, new JsonSerde().copyWithType(User.class)));
+ .stream(
+ usersInputTopic,
+ Consumed.with(null, new JsonSerde().copyWithType(User.class)))
+ .toTable(
+ Materialized
+ .<String, User>as(userStoreSupplier)
+ .withKeySerde(Serdes.String())
+ .withValueSerde(new JsonSerde().copyWithType(User.class)));