JsonSerde<Recording> recordSerde =
new JsonSerde<>(Recording.class).ignoreTypeHeaders();
- JsonSerde<Word> wordSerde =
- new JsonSerde<>(Word.class).noTypeInfo();
KStream<String, Recording> source = builder.stream(
properties.getInputTopic(),
.stream(PATTERN.split(recording.getSentence()))
.map(word -> Word.of(recording.getUser(), word))
.toList())
- .to(properties.getOutputTopic(), Produced.with(Serdes.String(), wordSerde));
+ .to(properties.getOutputTopic());
Properties props = new Properties();
props.put(StreamsConfig.APPLICATION_ID_CONFIG, properties.getApplicationId());