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 639d82fdb3350fb5274aec53bc6122f500b827d3..a90048c51022282eb97168f307076a5d36a0dbb7 100644 (file)
--- 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);
+  }
 }