Add deserialization exception handler example

Author: loicgreffier

README.md

@@ -1,6 +1,8 @@
 # Spring Boot and Kafka quickstarts
 
 [![GitHub Build](https://img.shields.io/github/actions/workflow/status/loicgreffier/spring-boot-kafka-quickstarts/continuous_integration.yml?branch=main&logo=github&style=for-the-badge)](https://github.com/loicgreffier/spring-boot-kafka-quickstarts/actions/workflows/continuous_integration.yml)
+[![Kafka Version](https://img.shields.io/badge/dynamic/xml?url=https%3A%2F%2Fraw.githubusercontent.com%2Floicgreffier%2Fspring-boot-kafka-quickstarts%2Fmain%2Fpom.xml&query=%2F*%5Blocal-name()%3D'project'%5D%2F*%5Blocal-name()%3D'properties'%5D%2F*%5Blocal-name()%3D'kafka.version'%5D%2Ftext()&style=for-the-badge&logo=apachekafka&label=version)](https://github.com/loicgreffier/spring-boot-kafka-quickstarts/blob/main/pom.xml)
+[![Spring Boot Version](https://img.shields.io/badge/dynamic/xml?url=https%3A%2F%2Fraw.githubusercontent.com%2Floicgreffier%2Fspring-boot-kafka-quickstarts%2Fmain%2Fpom.xml&query=%2F*%5Blocal-name()%3D'project'%5D%2F*%5Blocal-name()%3D'parent'%5D%2F*%5Blocal-name()%3D'version'%5D%2Ftext()&style=for-the-badge&logo=spring-boot&label=version)](https://github.com/loicgreffier/spring-boot-kafka-quickstarts/blob/main/pom.xml)
 [![GitHub Stars](https://img.shields.io/github/stars/loicgreffier/spring-boot-kafka-quickstarts?logo=github&style=for-the-badge)](https://github.com/loicgreffier/spring-boot-kafka-quickstarts)
 [![GitHub Watch](https://img.shields.io/github/watchers/loicgreffier/spring-boot-kafka-quickstarts?logo=github&style=for-the-badge)](https://github.com/loicgreffier/spring-boot-kafka-quickstarts)
 [![Docker Pulls](https://img.shields.io/docker/pulls/loicgreffier/spring-boot-kafka-quickstarts?label=Pulls&logo=docker&style=for-the-badge)](https://hub.docker.com/r/loicgreffier/spring-boot-kafka-quickstarts/tags)
@@ -112,3 +114,9 @@ This section contains quickstarts around the Kafka Streams API with unit tests u
 | [ProcessValues](/kafka-streams-quickstarts/kafka-streams-process-values)                  | Kafka Streams | Apply a fixed key processor to a stream                                 | `processValues()`              | `context()`, `forward()`, `Record#headers()` |
 | [Schedule](/kafka-streams-quickstarts/kafka-streams-schedule)                             | Kafka Streams | Schedule punctuation functions based on wall clock time and stream time | `process()`                    | `schedule()`, `getStateStore()`              |
 | [Schedule Store Cleanup](/kafka-streams-quickstarts/kafka-streams-schedule-store-cleanup) | Kafka Streams | Schedule periodic store cleanup based on stream time                    | `process()`, `addStateStore()` | `schedule()`                                 |
+
+#### Handler
+
+| Module                                                                                                          | Library       | Content                                                                      | Config                                      |
+|:----------------------------------------------------------------------------------------------------------------|---------------|------------------------------------------------------------------------------|---------------------------------------------|
+| [Deserialization Exception Handler](/kafka-streams-quickstarts/kafka-streams-deserialization-exception-handler) | Kafka Streams | Handle deserialization exceptions and forward records to a dead letter queue | `default.deserialization.exception.handler` |

kafka-consumer-quickstarts/kafka-consumer-avro-specific/pom.xml

@@ -2,12 +2,12 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
     <parent>
-        <artifactId>kafka-consumer-quickstarts</artifactId>
         <groupId>io.github.loicgreffier</groupId>
+        <artifactId>kafka-consumer-quickstarts</artifactId>
         <version>1.0.0</version>
     </parent>
-    <modelVersion>4.0.0</modelVersion>
 
     <artifactId>kafka-consumer-avro-specific</artifactId>
 

kafka-consumer-quickstarts/kafka-consumer-circuit-breaker/pom.xml

@@ -2,12 +2,12 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
     <parent>
-        <artifactId>kafka-consumer-quickstarts</artifactId>
         <groupId>io.github.loicgreffier</groupId>
+        <artifactId>kafka-consumer-quickstarts</artifactId>
         <version>1.0.0</version>
     </parent>
-    <modelVersion>4.0.0</modelVersion>
 
     <artifactId>kafka-consumer-circuit-breaker</artifactId>
 

kafka-consumer-quickstarts/kafka-consumer-headers/pom.xml

@@ -10,11 +10,4 @@
     </parent>
 
     <artifactId>kafka-consumer-headers</artifactId>
-
-    <properties>
-        <maven.compiler.source>21</maven.compiler.source>
-        <maven.compiler.target>21</maven.compiler.target>
-        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-    </properties>
-
 </project>

kafka-consumer-quickstarts/kafka-consumer-retry-external-system/pom.xml

@@ -2,12 +2,12 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
     <parent>
-        <artifactId>kafka-consumer-quickstarts</artifactId>
         <groupId>io.github.loicgreffier</groupId>
+        <artifactId>kafka-consumer-quickstarts</artifactId>
         <version>1.0.0</version>
     </parent>
-    <modelVersion>4.0.0</modelVersion>
 
     <artifactId>kafka-consumer-retry-external-system</artifactId>
 </project>

kafka-consumer-quickstarts/kafka-consumer-simple/pom.xml

@@ -2,12 +2,12 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
     <parent>
-        <artifactId>kafka-consumer-quickstarts</artifactId>
         <groupId>io.github.loicgreffier</groupId>
+        <artifactId>kafka-consumer-quickstarts</artifactId>
         <version>1.0.0</version>
     </parent>
-    <modelVersion>4.0.0</modelVersion>
 
     <artifactId>kafka-consumer-simple</artifactId>
 </project>

kafka-consumer-quickstarts/kafka-consumer-transaction/pom.xml

@@ -2,12 +2,12 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
     <parent>
-        <artifactId>kafka-consumer-quickstarts</artifactId>
         <groupId>io.github.loicgreffier</groupId>
+        <artifactId>kafka-consumer-quickstarts</artifactId>
         <version>1.0.0</version>
     </parent>
-    <modelVersion>4.0.0</modelVersion>
 
     <artifactId>kafka-consumer-transaction</artifactId>
 </project>

kafka-consumer-quickstarts/pom.xml

@@ -2,13 +2,13 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
     <parent>
-        <artifactId>spring-boot-kafka-quickstarts</artifactId>
         <groupId>io.github.loicgreffier</groupId>
+        <artifactId>spring-boot-kafka-quickstarts</artifactId>
         <version>1.0.0</version>
     </parent>
 
-    <modelVersion>4.0.0</modelVersion>
     <packaging>pom</packaging>
 
     <modules>

kafka-producer-quickstarts/kafka-producer-avro-specific/pom.xml

@@ -2,12 +2,12 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
     <parent>
-        <artifactId>kafka-producer-quickstarts</artifactId>
         <groupId>io.github.loicgreffier</groupId>
+        <artifactId>kafka-producer-quickstarts</artifactId>
         <version>1.0.0</version>
     </parent>
-    <modelVersion>4.0.0</modelVersion>
 
     <artifactId>kafka-producer-avro-specific</artifactId>
 

kafka-producer-quickstarts/kafka-producer-simple/pom.xml

@@ -2,12 +2,12 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
     <parent>
-        <artifactId>kafka-producer-quickstarts</artifactId>
         <groupId>io.github.loicgreffier</groupId>
+        <artifactId>kafka-producer-quickstarts</artifactId>
         <version>1.0.0</version>
     </parent>
-    <modelVersion>4.0.0</modelVersion>
 
     <artifactId>kafka-producer-simple</artifactId>
 </project>