I have a cluster with 3 persistent nodes. And I am persisting the events into cassandra datastore (5 cluster nodes). I am using akka-persistence-cassandra plugin (version 0.91) from Akka.
After some time of working there was a problem.
In the tag_write_progress table i have mismatch of sequence_nr and tag_pid_sequence_nr. And because of it when i am projecting data to elasticsearch with help of evetsByTag method i have problem with number of events . Like in example only last two events (number 9 and 10) fall into elastic index.
Can you help me with this? Thank you!