juplo.de Git - demos/kafka/training/blob - src/main/java/de/juplo/kafka/StateDocument.java

   1 package de.juplo.kafka;
   2
   3 import lombok.ToString;
   4 import org.springframework.data.annotation.Id;
   5 import org.springframework.data.mongodb.core.mapping.Document;
   6
   7 import java.util.HashMap;
   8 import java.util.List;
   9 import java.util.Map;
  10
  11
  12 @Document(collection = "statistics")
  13 @ToString
  14 public class StateDocument
  15 {
  16   @Id
  17   public String id;
  18   public long offset = -1l;
  19   public Map<String, Long> state;
  20
  21   public StateDocument()
  22   {
  23   }
  24
  25   public StateDocument(Integer partition)
  26   {
  27     this.id = Integer.toString(partition);
  28     this.state = new HashMap<>();
  29   }
  30
  31   public StateDocument(
  32       Integer partition,
  33       Map<String, Long> state,
  34       long offset)
  35   {
  36     this.id = Integer.toString(partition);
  37     this.state = state;
  38     this.offset = offset;
  39   }
  40 }