Fehler im Shutdown-Code korrigiert: Shutdown von `EndlessConsumer` zu spät
[demos/kafka/training] / src / main / java / de / juplo / kafka / StatisticsDocument.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.Map;
9
10
11 @Document(collection = "statistics")
12 @ToString
13 public class StatisticsDocument
14 {
15   @Id
16   public String id;
17   public long offset;
18   public Map<String, Long> statistics;
19
20   public StatisticsDocument()
21   {
22   }
23
24   public StatisticsDocument(Integer partition)
25   {
26     this.id = Integer.toString(partition);
27     this.statistics = new HashMap<>();
28   }
29
30   public StatisticsDocument(Integer partition, Map<String, Long> statistics, long offset)
31   {
32     this.id = Integer.toString(partition);
33     this.statistics = statistics;
34     this.offset = offset;
35   }
36 }