1 package de.juplo.kafka;
3 import lombok.ToString;
4 import org.springframework.data.annotation.Id;
5 import org.springframework.data.mongodb.core.mapping.Document;
7 import java.util.HashMap;
11 @Document(collection = "statistics")
13 public class StatisticsDocument
18 public Integer partition;
19 public Map<String, Long> statistics;
21 public StatisticsDocument()
25 public StatisticsDocument(String topic, Integer partition, Map<String, Long> statistics)
27 this.partition = partition;
28 this.statistics = statistics;
31 public StatisticsDocument(PartitionStatistics statistics)
33 this.topic = statistics.getPartition().topic();
34 this.id = statistics.toString();
35 this.partition = statistics.getPartition().partition();
36 this.statistics = new HashMap<>();
37 statistics.getStatistics().forEach(counter -> this.statistics.put(counter.getKey(), counter.getResult()));