From: Kai Moritz <kai@juplo.de>
Date: Fri, 17 Feb 2023 16:28:54 +0000 (+0100)
Subject: counter: 1.2.4 - Headers for type-mapping are not necessary
X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Fwordcount;a=commitdiff_plain;h=dd4d5ddb60f7ca495d65d49f93eb4c07e0d03e22

counter: 1.2.4 - Headers for type-mapping are not necessary
---

diff --git a/pom.xml b/pom.xml
index cbccc73..ba143ec 100644
--- a/pom.xml
+++ b/pom.xml
@@ -10,7 +10,7 @@
 	</parent>
 	<groupId>de.juplo.kafka.wordcount</groupId>
 	<artifactId>counter</artifactId>
-	<version>1.2.3</version>
+	<version>1.2.4</version>
 	<name>Wordcount-Counter</name>
 	<description>Word-counting stream-processor of the multi-user wordcount-example</description>
 	<properties>
diff --git a/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplicationConfiguriation.java b/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplicationConfiguriation.java
index 1bcc834..97ad022 100644
--- a/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplicationConfiguriation.java
+++ b/src/main/java/de/juplo/kafka/wordcount/counter/CounterApplicationConfiguriation.java
@@ -35,13 +35,11 @@ public class CounterApplicationConfiguriation
 		propertyMap.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, properties.getBootstrapServer());
 		propertyMap.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, JsonSerde.class.getName());
 		propertyMap.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, JsonSerde.class.getName());
+		propertyMap.put(JsonSerializer.ADD_TYPE_INFO_HEADERS, false);
 		propertyMap.put(JsonDeserializer.TRUSTED_PACKAGES, Word.class.getPackageName());
 		propertyMap.put(JsonDeserializer.KEY_DEFAULT_TYPE, Word.class.getName());
 		propertyMap.put(JsonDeserializer.VALUE_DEFAULT_TYPE, Word.class.getName());
-		propertyMap.put(
-				JsonDeserializer.TYPE_MAPPINGS,
-				"W:" + Word.class.getName() + "," +
-				"C:" + WordCount.class.getName());
+		propertyMap.put(JsonDeserializer.USE_TYPE_INFO_HEADERS, false);
 		propertyMap.put(StreamsConfig.STATE_DIR_CONFIG, "target");
 		if (properties.getCommitInterval() != null)
 			propertyMap.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, properties.getCommitInterval());