akka-edge rust implementation has offset-store.
It has GetLastOffset GetOffset and SaveOffset
What is the purpose of GetLastOffset.
How is it used to pause/resume or crash/resume scenarios?
I found the answer. GetLastOffset is list of values. It means it will contain all offsets for each entity being processed.
In rust it is implemented as below
last_offsets: Vec
It allows for single offset_store instance for all the entities.
It can be used for count the offset values with out needing to hit the database.
In case of pause/resume the individual offset is used.