counting-consumer ist eine Verbesserung von endless-consumer

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

diff --git a/src/main/java/de/juplo/kafka/KeyCounter.java b/src/main/java/de/juplo/kafka/KeyCounter.java
index 147dcd4..b2cde47 100644 (file)
--- 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;
   }
 }