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

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 463621a8f90250de36aa1f7f74061261775e3d7f..ae5906a69928d99f0ed44aea5e721f29cbd81ec0 100644 (file)
--- 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);