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=bb1c7019b2400ba2e63173104e4f8aa6133c64c4;hb=4abc82d5d4cc80feabee91a10749b40f9bcfd879;hp=0000000000000000000000000000000000000000;hpb=2768e0f97c441ade5ce8ff371aa590fdc3cfd6c6;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..bb1c701
--- /dev/null
+++ b/src/main/java/de/juplo/kafka/StateDocument.java
@@ -0,0 +1,36 @@
+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.Map;
+
+
+@Document(collection = "state")
+@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;
+  }
+}