From d84df9a33b1e2cdcc11f1981066b8b5c7d2eece5 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 15 Mar 2026 21:08:17 +0100
Subject: [PATCH] Upgrade von Spring-Boot 3.4.1 -> 4.0.2
 (spring/spring-producer--messageconverter)

---
 .../juplo/kafka/ApplicationConfiguration.java | 24 +++++++++----------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 57fa246f..0e3e2fdb 100644
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -1,18 +1,18 @@
 package de.juplo.kafka;
 
-import com.fasterxml.jackson.databind.ObjectMapper;
 import org.springframework.beans.factory.annotation.Value;
-import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.boot.kafka.autoconfigure.KafkaProperties;
 import org.springframework.context.ConfigurableApplicationContext;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.kafka.core.ProducerFactory;
-import org.springframework.kafka.support.converter.ByteArrayJsonMessageConverter;
-import org.springframework.kafka.support.converter.JsonMessageConverter;
-import org.springframework.kafka.support.mapping.DefaultJackson2JavaTypeMapper;
-import org.springframework.kafka.support.mapping.Jackson2JavaTypeMapper;
+import org.springframework.kafka.support.converter.ByteArrayJacksonJsonMessageConverter;
+import org.springframework.kafka.support.converter.JacksonJsonMessageConverter;
+import org.springframework.kafka.support.mapping.DefaultJacksonJavaTypeMapper;
+import org.springframework.kafka.support.mapping.JacksonJavaTypeMapper;
+import tools.jackson.databind.ObjectMapper;
 
 import java.time.Duration;
 import java.util.HashMap;
@@ -46,22 +46,22 @@ public class ApplicationConfiguration
   @Bean
   public KafkaTemplate<String, SumupMessage> kafkaTemplate(
     ProducerFactory<String, SumupMessage> producerFactory,
-    JsonMessageConverter jsonMessageConverter) {
+    JacksonJsonMessageConverter jacksonJsonMessageConverter) {
 
     KafkaTemplate<String, SumupMessage> template = new KafkaTemplate<>(producerFactory);
-    template.setMessageConverter(jsonMessageConverter);
+    template.setMessageConverter(jacksonJsonMessageConverter);
 
     return template;
   }
 
   @Bean
-  public ByteArrayJsonMessageConverter jsonMessageConverter(ObjectMapper objectMapper)
+  public ByteArrayJacksonJsonMessageConverter jacksonJsonMessageConverter(ObjectMapper objectMapper)
   {
-    ByteArrayJsonMessageConverter converter = new ByteArrayJsonMessageConverter();
-    DefaultJackson2JavaTypeMapper typeMapper = new DefaultJackson2JavaTypeMapper();
+    ByteArrayJacksonJsonMessageConverter converter = new ByteArrayJacksonJsonMessageConverter();
+    DefaultJacksonJavaTypeMapper typeMapper = new DefaultJacksonJavaTypeMapper();
 
     // Verwende eine einfache, kurze Type-ID anstatt FQN
-    typeMapper.setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence.TYPE_ID);
+    typeMapper.setTypePrecedence(JacksonJavaTypeMapper.TypePrecedence.TYPE_ID);
     Map<String, Class<?>> typeMappings = new HashMap<>();
     typeMappings.put("ADD", AddNumberMessage.class);
     typeMappings.put("CALC", CalculateSumMessage.class);
-- 
2.39.5