From d233e0bd7f1f7afe3204cdabf0f759f26da1d67f Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Tue, 24 Mar 2026 17:29:59 +0100
Subject: [PATCH] =?utf8?q?Default-Handler=20erg=C3=A4nzt,=20der=20das=20Pr?=
 =?utf8?q?ogramm=20=C3=BCber=20eine=20Exception=20beendet?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 src/main/java/de/juplo/kafka/ExampleConsumer.java | 7 +++++++
 1 file changed, 7 insertions(+)

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);
+  }
 }
-- 
2.39.5