X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FKeyCounter.java;h=b2cde47904a9079a9ef9914911c876728ae97fc2;hb=9b6e51fc59bd5382afa42023045a6d40b9d7d4b7;hp=147dcd4f52368c5df053e3d05148ab3d22a778e3;hpb=32a052b7c494009c59190857984ef3563f4f2b14;p=demos%2Fkafka%2Ftraining

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;
   }
 }