From aae6a65352dec543b7ec6ddf502120454dee37d9 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