+ 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));
+