- JsonSerde<Recording> recordSerde =
- new JsonSerde<>(Recording.class).ignoreTypeHeaders();
- JsonSerde<Word> wordSerde =
- new JsonSerde<>(Word.class).noTypeInfo();
-
- KStream<String, Recording> source = builder.stream(
- properties.getInputTopic(),
- Consumed.with(Serdes.String(), recordSerde));