From e4725dc4bcafa8a024156bd6d5c3cc233f751d15 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Mon, 13 May 2024 20:34:31 +0200
Subject: [PATCH] counter: 1.2.4 - Headers for type-mapping are not necessary

---
 pom.xml                                                     | 2 +-
 .../wordcount/counter/CounterApplicationConfiguriation.java | 6 ++----
 2 files changed, 3 insertions(+), 5 deletions(-)

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 104b151..3e2d2e7 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, CounterApplication.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());
-- 
2.20.1