From: Kai Moritz <kai@juplo.de>
Date: Tue, 24 Mar 2026 16:29:59 +0000 (+0100)
Subject: Default-Handler ergänzt, der das Programm über eine Exception beendet
X-Git-Tag: springkafka/spring-consumer--messageconverter--2026-03-lvm~2
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=d233e0bd7f1f7afe3204cdabf0f759f26da1d67f;p=demos%2Fkafka%2Ftraining

Default-Handler ergänzt, der das Programm über eine Exception beendet
---

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 639d82fd..a90048c5 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -28,4 +28,11 @@ public class ExampleConsumer
   {
     log.info("{} - Calculating sum", id);
   }
+
+  @KafkaHandler(isDefault = true)
+  private void unknownMessage(Object message)
+  {
+    log.error("{} - Recived message of unknown type: {}", id, message);
+    throw new RuntimeException("Message of unknown type: " + message);
+  }
 }