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 = "state")
13 public class StateDocument
17 public Map<String, Long> state;
19 public StateDocument()
23 public StateDocument(Integer partition)
25 this.id = Integer.toString(partition);
26 this.state = new HashMap<>();
29 public StateDocument(Integer partition, Map<String, Long> state)
31 this.id = Integer.toString(partition);