X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FStateDocument.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2FStateDocument.java;h=2583c8efa8b4a20efea9889193c110639239169d;hb=5b4b7acf7b6a02e0e5c779257d3f5996366625e6;hp=0000000000000000000000000000000000000000;hpb=f83599b6aaefff62c286e2143bb2e8a81751e6fd;p=demos%2Fkafka%2Ftraining

diff --git a/src/main/java/de/juplo/kafka/StateDocument.java b/src/main/java/de/juplo/kafka/StateDocument.java
new file mode 100644
index 0000000..2583c8e
--- /dev/null
+++ b/src/main/java/de/juplo/kafka/StateDocument.java
@@ -0,0 +1,40 @@
+package de.juplo.kafka;
+
+import lombok.ToString;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+
+@Document(collection = "statistics")
+@ToString
+public class StateDocument
+{
+  @Id
+  public String id;
+  public long offset = -1l;
+  public Map<String, Long> state;
+
+  public StateDocument()
+  {
+  }
+
+  public StateDocument(Integer partition)
+  {
+    this.id = Integer.toString(partition);
+    this.state = new HashMap<>();
+  }
+
+  public StateDocument(
+      Integer partition,
+      Map<String, Long> state,
+      long offset)
+  {
+    this.id = Integer.toString(partition);
+    this.state = state;
+    this.offset = offset;
+  }
+}