Stored counter may be decreased by concurrent writer

eligosource / eventsourced

A library for building reliable, scalable and distributed event-sourced applications in Scala

Apache License 2.0

828 stars 98 forks source link

Stored counter may be decreased by concurrent writer #74

Closed krasserm closed 11 years ago

krasserm commented 11 years ago

Each writer must use its own counter key per partition i.e. the total number of counter keys must be numWriters * numPartitons.

krasserm commented 11 years ago

Comes up again because of missing ordering guarantees of HBaseClient.put. Fix with writing each counter value under a separate key (and a lower limit every x messages that can be used for efficient recovery).