Merge der überarbeiteten Compose-Konfiguration ('rebalance-listener')
[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 Map<String, Integer> statistics;
18
19   public StatisticsDocument()
20   {
21   }
22
23   public StatisticsDocument(Integer partition, Map<String, Integer> statistics)
24   {
25     this.id = Integer.toString(partition);
26     this.statistics = statistics;
27   }
28 }