From e990b20ab4d197b5f929487f036cbb470661aeb7 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sat, 1 Feb 2025 17:17:51 +0100
Subject: [PATCH] =?utf8?q?Fachliche=20Behandlung=20der=20unterschiedlichen?=
 =?utf8?q?=20Nachrichten-Typen=20erg=C3=A4nzt?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

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

diff --git a/src/main/java/de/juplo/kafka/ExampleConsumer.java b/src/main/java/de/juplo/kafka/ExampleConsumer.java
index a958aeff..c1397b9c 100644
--- a/src/main/java/de/juplo/kafka/ExampleConsumer.java
+++ b/src/main/java/de/juplo/kafka/ExampleConsumer.java
@@ -94,8 +94,23 @@ public class ExampleConsumer implements Runnable
   {
     consumed++;
     log.info("{} - partition={}-{}, offset={}: {}={}", id, topic, partition, offset, key, value);
+    switch (value.getType())
+    {
+      case ADD  -> addNumber((MessageAddNumber)value);
+      case CALC -> calcSum((MessageCalculateSum)value);
+      default   -> log.error("{} - Ignoring message of unknown typ {}", id, value.getType());
+    }
   }
 
+  private void addNumber(MessageAddNumber addNumber)
+  {
+    log.info("{} - Adding number {}", id, addNumber.getNext());
+  }
+
+  private void calcSum(MessageCalculateSum calculateSum)
+  {
+    log.info("{} - Calculating sum", id);
+  }
 
   public void shutdown() throws InterruptedException
   {
-- 
2.20.1