]> juplo.de Git - demos/kafka/training/commitdiff
Migration Spring-Boot 3.4.1 -> 4.0.2 (springkafka/spring-consumer--kafkahandler)
authorKai Moritz <kai@juplo.de>
Tue, 24 Mar 2026 16:57:50 +0000 (17:57 +0100)
committerKai Moritz <kai@juplo.de>
Tue, 24 Mar 2026 16:57:57 +0000 (17:57 +0100)
* Ohne die Anpassungen startet die Anwendung ohne Fehler...
* ...allerdings wird der `MessageListenerContainer` nicht gestartet!
* D.h., ohne die Anpassungen verarbeitet die Anwendung gar keine Nachrichten.

pom.xml
src/main/resources/application.yml

diff --git a/pom.xml b/pom.xml
index b8874dc705379e37ee7776368051d8662796f34c..b5fcc8f73d23a8f36f26793c6e6e3cc2bf8c60e5 100644 (file)
--- a/pom.xml
+++ b/pom.xml
   </properties>
 
   <dependencies>
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-kafka</artifactId>
+    </dependency>
     <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-web</artifactId>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-validation</artifactId>
     </dependency>
-    <dependency>
-      <groupId>org.springframework.kafka</groupId>
-      <artifactId>spring-kafka</artifactId>
-    </dependency>
     <dependency>
       <groupId>org.projectlombok</groupId>
       <artifactId>lombok</artifactId>
index b3e33585a3904e712a17473cb786240782b1fc43..8c09c9c1e8beba7a9f3d98c0bdb3cbd43b85b687 100644 (file)
@@ -27,7 +27,7 @@ spring:
     client-id: DEV
     consumer:
       group-id: my-group
-      value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
+      value-deserializer: org.springframework.kafka.support.serializer.JacksonJsonDeserializer
       properties:
         "[spring.json.type.mapping]": ADD:de.juplo.kafka.MessageAddNumber,CALC:de.juplo.kafka.MessageCalculateSum
   level: