Currently the OffsetStorageReader only reads the offsets that have been committed. This is a good consistency model but read-your-write consistency model is needed to simplify connector development.
Read-your-writes consistency
A value written by a process on a data item X will be always available to a successive read operation performed by the same process on data item X.
Currently the OffsetStorageReader only reads the offsets that have been committed. This is a good consistency model but read-your-write consistency model is needed to simplify connector development.
Read-your-writes consistency A value written by a process on a data item X will be always available to a successive read operation performed by the same process on data item X.
More here: http://www.allthingsdistributed.com/2007/12/eventually_consistent.html