michelin · loicgreffier · Nov 22, 2025 · Nov 22, 2025
diff --git a/.docker/Dockerfile b/.docker/Dockerfile
diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml
@@ -7,8 +7,6 @@ on:
   pull_request:
     branches:
       - 'main'
-  schedule:
-    - cron: '0 5 * * 1'
 
 jobs:
   build:
@@ -20,10 +18,10 @@ jobs:
         with:
           fetch-depth: 0
 
-      - name: Set up JDK 21
+      - name: Set up JDK 25
         uses: actions/setup-java@v5
         with:
-          java-version: '21'
+          java-version: '25'
           distribution: 'temurin'
           cache: maven
 

diff --git a/.mvn/wrapper/maven-wrapper.properties b/.mvn/wrapper/maven-wrapper.properties
@@ -16,4 +16,4 @@
 # under the License.
 wrapperVersion=3.3.4
 distributionType=only-script
-distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.11/apache-maven-3.9.11-bin.zip
+distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.9.11/apache-maven-3.9.11-bin.zip
diff --git a/README.md b/README.md
@@ -18,7 +18,7 @@ Available since Apache Kafka 3.9.0, this example showcases the use of the Kafka
 
 ## Prerequisites
 
-- Java 21
+- Java 25
 - Maven
 - Docker
 

diff --git a/dsl/README.md b/dsl/README.md
@@ -6,7 +6,7 @@ This module demonstrates how to use the processing exception handler to manage p
 
 To compile and run this demo, you’ll need:
 
-- Java 21
+- Java 25
 - Maven
 - Docker
 

diff --git a/dsl/src/test/java/com/michelin/kafka/error/handling/dsl/KafkaStreamsAppTest.java b/dsl/src/test/java/com/michelin/kafka/error/handling/dsl/KafkaStreamsAppTest.java
@@ -65,9 +65,7 @@ static Stream<String> provideProcessingExceptionHandlerClassName() {
     void shouldContinueOnInvalidDeliveryAndNullPointerExceptions(String processingExceptionHandlerClassName) {
         instantiateTopologyTestDriver(processingExceptionHandlerClassName);
 
-        inputTopic.pipeInput(
-                "DEL12345",
-                """
+        inputTopic.pipeInput("DEL12345", """
         {
           "deliveryId": "DEL12345",
           "truckId": "TRK56789",
@@ -77,9 +75,7 @@ void shouldContinueOnInvalidDeliveryAndNullPointerExceptions(String processingEx
         """);
 
         // "numberOfTires" is negative. This will throw an InvalidDeliveryException
-        inputTopic.pipeInput(
-                "DEL73148",
-                """
+        inputTopic.pipeInput("DEL73148", """
         {
           "deliveryId": "DEL67145",
           "truckId": "TRK34567",
@@ -89,9 +85,7 @@ void shouldContinueOnInvalidDeliveryAndNullPointerExceptions(String processingEx
         """);
 
         // "numberOfTires" is missing. This will throw a NullPointerException
-        inputTopic.pipeInput(
-                "DEL73148",
-                """
+        inputTopic.pipeInput("DEL73148", """
         {
           "deliveryId": "DEL73148",
           "truckId": "TRK48612",

diff --git a/pom.xml b/pom.xml
@@ -19,9 +19,9 @@
         <junit-jupiter.version>6.0.1</junit-jupiter.version>
         <kafka-streams.version>4.1.1</kafka-streams.version>
         <logback.version>1.5.21</logback.version>
-        <maven.compiler.source>21</maven.compiler.source>
-        <maven.compiler.target>21</maven.compiler.target>
-        <palantir.version>2.58.0</palantir.version>
+        <maven.compiler.source>25</maven.compiler.source>
+        <maven.compiler.target>25</maven.compiler.target>
+        <palantir.version>2.82.0</palantir.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <slf4j-api.version>2.0.17</slf4j-api.version>
         <sonar.host.url>https://sonarcloud.io</sonar.host.url>
@@ -150,7 +150,7 @@
                 <version>${jib-maven-plugin.version}</version>
                 <configuration>
                     <from>
-                        <image>eclipse-temurin:21-jre-alpine</image>
+                        <image>eclipse-temurin:25-jre-alpine</image>
                         <platforms>
                             <platform>
                                 <architecture>amd64</architecture>

diff --git a/processor-api/README.md b/processor-api/README.md
@@ -6,7 +6,7 @@ This module demonstrates how to use the processing exception handler to manage p
 
 To compile and run this demo, you’ll need:
 
-- Java 21
+- Java 25
 - Maven
 - Docker
 

diff --git a/processor-api/src/test/java/com/michelin/kafka/error/handling/papi/KafkaStreamsAppTest.java b/processor-api/src/test/java/com/michelin/kafka/error/handling/papi/KafkaStreamsAppTest.java
@@ -66,9 +66,7 @@ static Stream<String> provideProcessingExceptionHandlerClassName() {
     void shouldContinueOnInvalidDeliveryAndNullPointerExceptions(String processingExceptionHandlerClassName) {
         instantiateTopologyTestDriver(processingExceptionHandlerClassName);
 
-        inputTopic.pipeInput(
-                "DEL12345",
-                """
+        inputTopic.pipeInput("DEL12345", """
         {
           "deliveryId": "DEL12345",
           "truckId": "TRK56789",
@@ -78,9 +76,7 @@ void shouldContinueOnInvalidDeliveryAndNullPointerExceptions(String processingEx
         """);
 
         // "numberOfTires" is negative. This will throw an InvalidDeliveryException
-        inputTopic.pipeInput(
-                "DEL73148",
-                """
+        inputTopic.pipeInput("DEL73148", """
         {
           "deliveryId": "DEL67145",
           "truckId": "TRK34567",
@@ -90,9 +86,7 @@ void shouldContinueOnInvalidDeliveryAndNullPointerExceptions(String processingEx
         """);
 
         // "numberOfTires" is missing. This will throw a NullPointerException
-        inputTopic.pipeInput(
-                "DEL73148",
-                """
+        inputTopic.pipeInput("DEL73148", """
         {
           "deliveryId": "DEL73148",
           "truckId": "TRK48612",
-Original file line number
+Diff line change
@@ Expand Up @@
     ## Prerequisites
-    - Java 21
+    - Java 25
     - Maven
     - Docker
@@ Expand Down @@