From 31cbcf64f6ce68e1df60f1a7283393502d521531 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 1 Apr 2022 15:32:41 +0200
Subject: [PATCH] Vorlage

---
 .../java/de/juplo/kafka/EndlessConsumer.java  | 19 +------------------
 1 file changed, 1 insertion(+), 18 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/EndlessConsumer.java b/src/main/java/de/juplo/kafka/EndlessConsumer.java
index b3dd446..b64a95e 100644
--- a/src/main/java/de/juplo/kafka/EndlessConsumer.java
+++ b/src/main/java/de/juplo/kafka/EndlessConsumer.java
@@ -68,24 +68,7 @@ public class EndlessConsumer implements Runnable
 
       while (true)
       {
-        ConsumerRecords<String, String> records =
-            consumer.poll(Duration.ofSeconds(1));
-
-        // Do something with the data...
-        log.info("{} - Received {} messages", id, records.count());
-        for (ConsumerRecord<String, String> record : records)
-        {
-          consumed++;
-          log.info(
-              "{} - {}: {}/{} - {}={}",
-              id,
-              record.offset(),
-              record.topic(),
-              record.partition(),
-              record.key(),
-              record.value()
-          );
-        }
+        // TODO: Nachrichten abrufen und verarbeiten
       }
     }
     catch(WakeupException e)
-- 
2.20.1