From 705186ddbfb1fb9b8b99f54f3b418d909feca242 Mon Sep 17 00:00:00 2001
From: sam-gardner <53271849+sam-gardner@users.noreply.github.com>
Date: Mon, 4 Mar 2024 21:08:21 +0000
Subject: [PATCH] JAVA-31563-update-spring-kafka-to-latest-version (#15999)

* JAVA-31563-update-spring-kafka-to-latest-version

* JAVA-31563 Upgrade kafka in spring-boot-libraries-3
---
 spring-boot-modules/spring-boot-3-2/pom.xml                | 7 +++++++
 spring-boot-modules/spring-boot-libraries-3/pom.xml        | 3 ++-
 spring-kafka/pom.xml                                       | 2 ++
 .../com/baeldung/spring/kafka/KafkaConsumerConfig.java     | 2 +-
 4 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/spring-boot-modules/spring-boot-3-2/pom.xml b/spring-boot-modules/spring-boot-3-2/pom.xml
index d64d7e53f6..29ad9898fb 100644
--- a/spring-boot-modules/spring-boot-3-2/pom.xml
+++ b/spring-boot-modules/spring-boot-3-2/pom.xml
@@ -172,10 +172,12 @@
         <dependency>
             <groupId>org.springframework.kafka</groupId>
             <artifactId>spring-kafka</artifactId>
+            <version>${spring-kafka.version}</version>
         </dependency>
         <dependency>
             <groupId>org.springframework.kafka</groupId>
             <artifactId>spring-kafka-test</artifactId>
+            <version>${spring-kafka.version}</version>
             <scope>test</scope>
         </dependency>
         <dependency>
@@ -277,6 +279,10 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>17</source>
+                    <target>17</target>
+                </configuration>
             </plugin>
         </plugins>
     </build>
@@ -289,6 +295,7 @@
         <mockserver.version>5.14.0</mockserver.version>
         <lombok-mapstruct-binding.version>0.2.0</lombok-mapstruct-binding.version>
         <jedis.version>5.0.2</jedis.version>
+        <spring-kafka.version>3.1.2</spring-kafka.version>
     </properties>
 
 </project>
diff --git a/spring-boot-modules/spring-boot-libraries-3/pom.xml b/spring-boot-modules/spring-boot-libraries-3/pom.xml
index 43d8be84a4..0fc72abb64 100644
--- a/spring-boot-modules/spring-boot-libraries-3/pom.xml
+++ b/spring-boot-modules/spring-boot-libraries-3/pom.xml
@@ -19,6 +19,7 @@
         <dependency>
             <groupId>org.springframework.kafka</groupId>
             <artifactId>spring-kafka</artifactId>
+            <version>${spring-kafka.version}</version>
         </dependency>
 
         <dependency>
@@ -80,10 +81,10 @@
 
     <properties>
         <java.version>17</java.version>
-        <spring-boot.version>3.1.5</spring-boot.version>
         <spring-modulith-events-kafka.version>1.1.2</spring-modulith-events-kafka.version>
         <testcontainers.version>1.19.3</testcontainers.version>
         <awaitility.version>4.2.0</awaitility.version>
+        <spring-kafka.version>3.1.2</spring-kafka.version>
     </properties>
 
 </project>
\ No newline at end of file
diff --git a/spring-kafka/pom.xml b/spring-kafka/pom.xml
index 6428734de2..4a8267b7e3 100644
--- a/spring-kafka/pom.xml
+++ b/spring-kafka/pom.xml
@@ -36,6 +36,7 @@
         <dependency>
             <groupId>org.springframework.kafka</groupId>
             <artifactId>spring-kafka</artifactId>
+            <version>${spring-kafka.version}</version>
         </dependency>
         <dependency>
             <groupId>org.apache.kafka</groupId>
@@ -94,6 +95,7 @@
         <spring-boot-starter-actuator.version>3.0.5</spring-boot-starter-actuator.version>
         <micrometer-registry-prometheus.version>1.10.5</micrometer-registry-prometheus.version>
         <testcontainers-kafka.version>1.19.3</testcontainers-kafka.version>
+        <spring-kafka.version>3.1.2</spring-kafka.version>
     </properties>
 
 </project>
\ No newline at end of file
diff --git a/spring-kafka/src/main/java/com/baeldung/spring/kafka/KafkaConsumerConfig.java b/spring-kafka/src/main/java/com/baeldung/spring/kafka/KafkaConsumerConfig.java
index e8aa63a88d..6d3ba2b4d9 100644
--- a/spring-kafka/src/main/java/com/baeldung/spring/kafka/KafkaConsumerConfig.java
+++ b/spring-kafka/src/main/java/com/baeldung/spring/kafka/KafkaConsumerConfig.java
@@ -116,7 +116,7 @@ public class KafkaConsumerConfig {
     public ConcurrentKafkaListenerContainerFactory<String, Object> multiTypeKafkaListenerContainerFactory() {
         ConcurrentKafkaListenerContainerFactory<String, Object> factory = new ConcurrentKafkaListenerContainerFactory<>();
         factory.setConsumerFactory(multiTypeConsumerFactory());
-        factory.setMessageConverter(multiTypeConverter());
+        factory.setRecordMessageConverter(multiTypeConverter());
         return factory;
     }