Benennung der neuen fachlichen Klassen verbessert

[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 e3a60b5..c7bc852 100644 (file)
--- a/src/main/java/de/juplo/kafka/EndlessConsumer.java
+++ b/src/main/java/de/juplo/kafka/EndlessConsumer.java
@@ -83,7 +83,7 @@ public class EndlessConsumer implements Runnable
               log.info(
                   "{} - Seen {} messages for partition={}|key={}",
                   id,
-                  counter.getCounter(),
+                  counter.getResult(),
                   removed.getPartition(),
                   counter.getKey());
             }