`EndlessConsumer` nimmt jetzt einzelne `ConsumerRecord`s entgegen

[demos/kafka/training] / src / main / java / de / juplo / kafka / EndlessConsumer.java

diff --git a/src/main/java/de/juplo/kafka/EndlessConsumer.java b/src/main/java/de/juplo/kafka/EndlessConsumer.java
index d3d11ae..01397a2 100644 (file)
--- a/src/main/java/de/juplo/kafka/EndlessConsumer.java
+++ b/src/main/java/de/juplo/kafka/EndlessConsumer.java
@@ -26,14 +26,9 @@ public class EndlessConsumer<K, V>
       id = "${spring.kafka.client-id}",
       idIsGroup = false,
       topics = "${sumup.adder.topic}",
-      batch = "true",
       autoStartup = "false")
-  public void accept(List<ConsumerRecord<K, V>> records)
+  public void accept(ConsumerRecord<K, V> record)
   {
-        // Do something with the data...
-        log.info("{} - Received {} messages", id, records.size());
-        for (ConsumerRecord<K, V> record : records)
-        {
           log.info(
               "{} - {}: {}/{} - {}={}",
               id,
@@ -47,7 +42,6 @@ public class EndlessConsumer<K, V>
           recordHandler.accept(record);
 
           consumed++;
-        }
   }
 
   public void start()