From: Kai Moritz <kai@juplo.de>
Date: Tue, 24 Mar 2026 16:31:33 +0000 (+0100)
Subject: Migration Spring-Boot 3.4.1 -> 4.0.2 (springkafka/spring-consumer--kafkahandler-... 
X-Git-Tag: springkafka/spring-consumer--messageconverter--2026-03-lvm~1
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=a83279f77a17d96466c84ac7754d6bc81a74496d;p=demos%2Fkafka%2Ftraining

Migration Spring-Boot 3.4.1 -> 4.0.2 (springkafka/spring-consumer--kafkahandler--messageconverter)
---

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 463621a8..ae5906a6 100644
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -1,11 +1,11 @@
 package de.juplo.kafka;
 
-import com.fasterxml.jackson.databind.ObjectMapper;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
-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.JacksonJsonMessageConverter;
+import org.springframework.kafka.support.mapping.DefaultJacksonJavaTypeMapper;
+import org.springframework.kafka.support.mapping.JacksonJavaTypeMapper;
+import tools.jackson.databind.ObjectMapper;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -18,16 +18,16 @@ public class ApplicationConfiguration
   // to instantiate a ByteArrayMessageConverter, because Spring never
   // calls the optimized method convertPayload(Message).
   @Bean
-  JsonMessageConverter jsonMessageConverter(ObjectMapper objectMapper)
+  JacksonJsonMessageConverter jacksonJsonMessageConverter(ObjectMapper objectMapper)
   {
-    JsonMessageConverter converter = new JsonMessageConverter();
-    DefaultJackson2JavaTypeMapper typeMapper = new DefaultJackson2JavaTypeMapper();
+    JacksonJsonMessageConverter converter = new JacksonJsonMessageConverter();
+    DefaultJacksonJavaTypeMapper typeMapper = new DefaultJacksonJavaTypeMapper();
 
     Map<String, Class<?>> typeMappings = new HashMap<>();
     typeMappings.put("ADD", MessageAddNumber.class);
     typeMappings.put("CALC", MessageCalculateSum.class);
 
-    typeMapper.setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence.TYPE_ID);
+    typeMapper.setTypePrecedence(JacksonJavaTypeMapper.TypePrecedence.TYPE_ID);
     typeMapper.setIdClassMapping(typeMappings);
 
     converter.setTypeMapper(typeMapper);