X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fsplitter%2FSplitterStreamProcessor.java;h=5e4930dfb151f927d1594894c2631d062aadf55e;hb=5a5616b76c58e030a0529426d281548bdf1d835f;hp=12816ab4e27d8a111f24b683afefcb9835981e85;hpb=cbabb637d0332ef3d8c67faf63e6e6897a69977f;p=demos%2Fkafka%2Fwordcount

diff --git a/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterStreamProcessor.java b/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterStreamProcessor.java
index 12816ab..5e4930d 100644
--- a/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterStreamProcessor.java
+++ b/src/main/java/de/juplo/kafka/wordcount/splitter/SplitterStreamProcessor.java
@@ -41,8 +41,6 @@ public class SplitterStreamProcessor
 
 		JsonSerde<Recording> recordSerde =
 				new JsonSerde<>(Recording.class).ignoreTypeHeaders();
-		JsonSerde<Word> wordSerde =
-				new JsonSerde<>(Word.class).noTypeInfo();
 
 		KStream<String, Recording> source = builder.stream(
 				properties.getInputTopic(),
@@ -53,7 +51,7 @@ public class SplitterStreamProcessor
 							.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());