From: Kai Moritz <kai@juplo.de>
Date: Fri, 16 May 2025 05:17:36 +0000 (+0200)
Subject: Fachlichen Fehler erzeugt
X-Git-Tag: springkafka/spring-consumer--messageconverter--dlt--2026-03-lvm
X-Git-Url: https://juplo.de/gitweb/?a=commitdiff_plain;h=be494e42452d4c9ba2ee4f074dc4acb629560a58;p=demos%2Fkafka%2Ftraining

Fachlichen Fehler erzeugt
---

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