I am trying to figure out how akka sharding and persistence play together.
Suppose there is an
persistenceId = "SomeActor-"+self.path.name and cassandra journal. Also we start
extractEntityId equals to some business entity id.
What is interesting is how the recovery process will occur in case cluster has been shutdowned and then restarted.
Will it try to recover all actors state at once after restart? But in that case akka-persistence needs to know
persistenceId to replay events from cassandra, but how we get
persistenceId if it bounds to actor path itself (and actor is created when first message comes ??? ).I am just confused with it.
Thanks in advance for explanation!