iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

JAVA-31563-update-spring-kafka-to-latest-version (#15999)

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

* JAVA-31563 Upgrade kafka in spring-boot-libraries-3
This commit is contained in:
sam-gardner 2024-03-04 21:08:21 +00:00 committed by GitHub
parent a92756154d
commit 705186ddbf
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
spring-boot-modules/spring-boot-3-2/pom.xml
View File

@ -172,10 +172,12 @@
<dependency> <dependency>
<groupId>org.springframework.kafka</groupId> <groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId> <artifactId>spring-kafka</artifactId>
<version>${spring-kafka.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.springframework.kafka</groupId> <groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka-test</artifactId> <artifactId>spring-kafka-test</artifactId>
<version>${spring-kafka.version}</version>
<scope>test</scope> <scope>test</scope>
</dependency> </dependency>
<dependency> <dependency>
@ -277,6 +279,10 @@
<plugin> <plugin>
<groupId>org.apache.maven.plugins</groupId> <groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId> <artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>17</source>
<target>17</target>
</configuration>
</plugin> </plugin>
</plugins> </plugins>
</build> </build>
@ -289,6 +295,7 @@
<mockserver.version>5.14.0</mockserver.version> <mockserver.version>5.14.0</mockserver.version>
<lombok-mapstruct-binding.version>0.2.0</lombok-mapstruct-binding.version> <lombok-mapstruct-binding.version>0.2.0</lombok-mapstruct-binding.version>
<jedis.version>5.0.2</jedis.version> <jedis.version>5.0.2</jedis.version>
<spring-kafka.version>3.1.2</spring-kafka.version>
</properties> </properties>
</project> </project>

3
spring-boot-modules/spring-boot-libraries-3/pom.xml
View File

@ -19,6 +19,7 @@
<dependency> <dependency>
<groupId>org.springframework.kafka</groupId> <groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId> <artifactId>spring-kafka</artifactId>
<version>${spring-kafka.version}</version>
</dependency> </dependency>
<dependency> <dependency>
@ -80,10 +81,10 @@
<properties> <properties>
<java.version>17</java.version> <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> <spring-modulith-events-kafka.version>1.1.2</spring-modulith-events-kafka.version>
<testcontainers.version>1.19.3</testcontainers.version> <testcontainers.version>1.19.3</testcontainers.version>
<awaitility.version>4.2.0</awaitility.version> <awaitility.version>4.2.0</awaitility.version>
<spring-kafka.version>3.1.2</spring-kafka.version>
</properties> </properties>
</project> </project>

2
spring-kafka/pom.xml
View File

@ -36,6 +36,7 @@
<dependency> <dependency>
<groupId>org.springframework.kafka</groupId> <groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId> <artifactId>spring-kafka</artifactId>
<version>${spring-kafka.version}</version>
</dependency> </dependency>
<dependency> <dependency>
<groupId>org.apache.kafka</groupId> <groupId>org.apache.kafka</groupId>
@ -94,6 +95,7 @@
<spring-boot-starter-actuator.version>3.0.5</spring-boot-starter-actuator.version> <spring-boot-starter-actuator.version>3.0.5</spring-boot-starter-actuator.version>
<micrometer-registry-prometheus.version>1.10.5</micrometer-registry-prometheus.version> <micrometer-registry-prometheus.version>1.10.5</micrometer-registry-prometheus.version>
<testcontainers-kafka.version>1.19.3</testcontainers-kafka.version> <testcontainers-kafka.version>1.19.3</testcontainers-kafka.version>
<spring-kafka.version>3.1.2</spring-kafka.version>
</properties> </properties>
</project> </project>

2
spring-kafka/src/main/java/com/baeldung/spring/kafka/KafkaConsumerConfig.java
View File

@ -116,7 +116,7 @@ public class KafkaConsumerConfig {
public ConcurrentKafkaListenerContainerFactory<String, Object> multiTypeKafkaListenerContainerFactory() { public ConcurrentKafkaListenerContainerFactory<String, Object> multiTypeKafkaListenerContainerFactory() {
ConcurrentKafkaListenerContainerFactory<String, Object> factory = new ConcurrentKafkaListenerContainerFactory<>(); ConcurrentKafkaListenerContainerFactory<String, Object> factory = new ConcurrentKafkaListenerContainerFactory<>();
factory.setConsumerFactory(multiTypeConsumerFactory()); factory.setConsumerFactory(multiTypeConsumerFactory());
factory.setMessageConverter(multiTypeConverter()); factory.setRecordMessageConverter(multiTypeConverter());
return factory; return factory;
} }