From 149fa27c8d1fd65c4b9510ff34ae44b11529e549 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Wed, 6 Apr 2022 08:45:57 +0200
Subject: [PATCH] Benennung der neuen fachlichen Klassen verbessert

---
 src/main/java/de/juplo/kafka/EndlessConsumer.java | 2 +-
 src/main/java/de/juplo/kafka/KeyCounter.java      | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/de/juplo/kafka/EndlessConsumer.java b/src/main/java/de/juplo/kafka/EndlessConsumer.java
index e3a60b5..c7bc852 100644
--- 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());
             }
diff --git a/src/main/java/de/juplo/kafka/KeyCounter.java b/src/main/java/de/juplo/kafka/KeyCounter.java
index 147dcd4..b2cde47 100644
--- a/src/main/java/de/juplo/kafka/KeyCounter.java
+++ b/src/main/java/de/juplo/kafka/KeyCounter.java
@@ -14,11 +14,11 @@ public class KeyCounter
 {
   private final String key;
 
-  private long counter = 0;
+  private long result = 0;
 
 
   public long increment()
   {
-    return ++counter;
+    return ++result;
   }
 }
-- 
2.20.1