Fachlichen Fehler erzeugt

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index 639d82fdb3350fb5274aec53bc6122f500b827d3..8ad374d295d4944609941a7fedfa68a2a6e0589b 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -20,6 +20,7 @@ public class ExampleConsumer
   @KafkaHandler
   private void addNumber(MessageAddNumber addNumber)
   {
+    if (addNumber.getNext() % 66 == 0) throw new RuntimeException("BOOM: Fachlicher Fehler!");
     log.info("{} - Adding number {}", id, addNumber.getNext());
   }