ROT: Verbesserungen aus 'deserialization' in 'sumup-adder' gemerged
[demos/kafka/training] / 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 }