X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FKeyCounter.java;h=1e3cbd2745e76f3efb82390bd61b093aa1d27b6a;hb=915674ec49ba38b3716cc4ef53272e963f139677;hp=b2cde47904a9079a9ef9914911c876728ae97fc2;hpb=149fa27c8d1fd65c4b9510ff34ae44b11529e549;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 b2cde47..1e3cbd2 100644
--- a/src/main/java/de/juplo/kafka/KeyCounter.java
+++ b/src/main/java/de/juplo/kafka/KeyCounter.java
@@ -17,6 +17,13 @@ public class KeyCounter
   private long result = 0;
 
 
+  public KeyCounter(String key, long initialValue)
+  {
+    this.key = key;
+    this.result = initialValue;
+  }
+
+
   public long increment()
   {
     return ++result;