Fachlichen Fehler erzeugt

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index a90048c51022282eb97168f307076a5d36a0dbb7..c8d62bbbf2fc53d9f6174d92d41ce2369453363a 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());
   }