Spotless

Author: loicgreffier

README.md

@@ -8,7 +8,7 @@
 [![Kafka Version](https://img.shields.io/badge/dynamic/xml?url=https%3A%2F%2Fraw.githubusercontent.com%michelin%2Fprocessing-error-handling%2Fmain%2Fpom.xml&query=%2F*%5Blocal-name()%3D'project'%5D%2F*%5Blocal-name()%3D'properties'%5D%2F*%5Blocal-name()%3D'kafka-streams.version'%5D%2Ftext()&style=for-the-badge&logo=apachekafka&label=version)](https://github.com/michelin/processing-error-handling/blob/main/pom.xml)
 [![License](https://img.shields.io/badge/License-Apache%202.0-blue.svg?logo=apache&style=for-the-badge)](https://opensource.org/licenses/Apache-2.0)
 
-[Prerequisites](#Prerequisites) • [Examples](#examples)
+[Prerequisites](#prerequisites) • [Examples](#examples)
 
 Code sample for [KIP-1033](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1033%3A+Add+Kafka+Streams+exception+handler+for+exceptions+occurring+during+processing).
 

pom.xml

@@ -14,13 +14,13 @@
 
     <properties>
         <gson.version>2.10.1</gson.version>
+        <jib-maven-plugin.version>3.4.5</jib-maven-plugin.version>
         <junit-jupiter.version>5.12.1</junit-jupiter.version>
         <kafka-streams.version>4.0.0</kafka-streams.version>
         <logback.version>1.5.18</logback.version>
         <maven.compiler.source>21</maven.compiler.source>
         <maven.compiler.target>21</maven.compiler.target>
         <palantir.version>2.58.0</palantir.version>
-        <jib-maven-plugin.version>3.4.5</jib-maven-plugin.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <slf4j-api.version>2.0.17</slf4j-api.version>
         <spotless-maven-plugin.version>2.44.3</spotless-maven-plugin.version>
@@ -75,19 +75,6 @@
     <build>
         <finalName>${project.artifactId}</finalName>
         <plugins>
-            <plugin>
-                <groupId>com.google.cloud.tools</groupId>
-                <artifactId>jib-maven-plugin</artifactId>
-                <version>${jib-maven-plugin.version}</version>
-                <configuration>
-                    <from>
-                        <image>eclipse-temurin:21-jre-alpine</image>
-                    </from>
-                    <to>
-                        <image>docker.io/michelin/kafka-streams-processing-error-handling:${project.artifactId}-${project.version}</image>
-                    </to>
-                </configuration>
-            </plugin>
 
             <plugin>
                 <groupId>com.diffplug.spotless</groupId>
@@ -139,6 +126,19 @@
                     </execution>
                 </executions>
             </plugin>
+            <plugin>
+                <groupId>com.google.cloud.tools</groupId>
+                <artifactId>jib-maven-plugin</artifactId>
+                <version>${jib-maven-plugin.version}</version>
+                <configuration>
+                    <from>
+                        <image>eclipse-temurin:21-jre-alpine</image>
+                    </from>
+                    <to>
+                        <image>docker.io/michelin/kafka-streams-processing-error-handling:${project.artifactId}-${project.version}</image>
+                    </to>
+                </configuration>
+            </plugin>
         </plugins>
     </build>
 </project>

processor-api/src/main/java/com/michelin/kafka/error/handling/papi/CustomProcessingExceptionHandler.java

@@ -50,6 +50,8 @@ public void configure(Map<String, ?> map) {
     }
 
     private boolean isContinuableException(Exception exception) {
-        return exception instanceof JsonSyntaxException || exception instanceof NullPointerException || exception instanceof KaboomException;
+        return exception instanceof JsonSyntaxException
+                || exception instanceof NullPointerException
+                || exception instanceof KaboomException;
     }
 }

processor-api/src/test/java/com/michelin/kafka/error/handling/papi/KafkaStreamsAppTest.java

@@ -123,7 +123,7 @@ void shouldHandleExceptionsAndContinueProcessing() {
 
         assertEquals(3.0, testDriver.metrics().get(droppedRecordsTotalMetric()).metricValue());
         assertEquals(
-            0.03333333333333333,
+                0.03333333333333333,
                 testDriver.metrics().get(droppedRecordsRateMetric()).metricValue());
     }