splitter: 1.1.1 - The configured default-serde is used for serialization

- Dropped the specialized configuration for the serialization.
- This variant writes the unnecessary (becuase unused) header `__TypeId__`.

diff --git a/pom.xml b/pom.xml
index abe3a67..4018e22 100644 (file)
--- a/pom.xml
+++ b/pom.xml
@@ -10,7 +10,7 @@
        </parent>
        <groupId>de.juplo.kafka.wordcount</groupId>
        <artifactId>splitter</artifactId>
-       <version>1.1.0</version>
+       <version>1.1.1</version>
        <name>Wordcount-Splitter</name>
        <description>Stream-processor of the multi-user wordcount-example, that splits the sentences up into single words</description>
        <properties>

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 (file)
--- 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());

diff --git a/src/test/resources/logback-test.xml b/src/test/resources/logback-test.xml
new file mode 100644 (file)
index 0000000..6f4bdf8
--- /dev/null
+++ b/src/test/resources/logback-test.xml
@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration>
+    <include resource="org/springframework/boot/logging/logback/base.xml" />
+    <logger name="de.juplo.kafka.wordcount.splitter" level="DEBUG" />
+</configuration>