Die Key-Statistiken werden in einer MongoDB gespeichert

[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 b2cde47..1e3cbd2 100644 (file)
--- 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;