{
@Id
public String id;
- public long offset = -1l;
public Map<String, Long> state;
public StateDocument()
this.state = new HashMap<>();
}
- public StateDocument(Integer partition, Map<String, Long> state, long offset)
+ public StateDocument(Integer partition, Map<String, Long> state)
{
this.id = Integer.toString(partition);
this.state = state;
- this.offset = offset;
}
}