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 long offset = -1l;
18 public Map<String, Long> state;
20 public StateDocument()
24 public StateDocument(Integer partition)
26 this.id = Integer.toString(partition);
27 this.state = new HashMap<>();
32 Map<String, Long> state,
35 this.id = Integer.toString(partition);