akka-persistence-cassandra
akka-persistence-cassandra copied to clipboard
akka
A replicated Akka Persistence journal backed by Apache Cassandra
Events by tag writes are currently fully asynchronous. However if tag writes fall behind we could start slowing down event writes by not completing the asyncWrite Future when the buffer...
If storing event wrapped in `Tagged` it will be retrieved unwrapped in queries like `eventsByTag`.
`CassandraRecovery ` class implements the method. Following is the code ``` override def asyncReadHighestSequenceNr(persistenceId: String, fromSequenceNr: Long): Future[Long] = asyncHighestDeletedSequenceNumber(persistenceId).flatMap { h => asyncFindHighestSequenceNr(persistenceId, math.max(fromSequenceNr, h)) } ``` It reads...
As it stands various persistent query tests sporadically fail with ScyllaDB, particularly the `EventsByTagStageSpec`. A lot of time was spent working with/around Cassandra's undocumented/incorrectly documented semantics around logged batch isolation....
A system can get into a bad state where multiple clusters form (due to a split-brain scenario or deployment mistake) or multiple single instances of a non-clustered system are running....
`CassandraLauncher` works by extracting a bundled Cassandra JAR from its resource path to a directory passed by the caller. Currently, it [tests whether the `cassandra-bundle.jar` file already exists in that...
https://travis-ci.org/akka/akka-persistence-cassandra/jobs/357419611 ``` [info] EventsByPersistenceIdSpec: Picked up _JAVA_OPTIONS: -Xmx2048m -Xms512m 03/23 14:48:00 ERROR[main] o.a.c.s.StartupChecks - cassandra.jmx.local.port missing from cassandra-env.sh, unable to start local JMX service. [info] Cassandra query EventsByPersistenceId [info] -...
Depending on which query I run, sometimes I want delayedEventTimeout and sometimes not, expose it in API, not only in config file
Updates [de.heikoseeberger:sbt-header](https://github.com/sbt/sbt-header) from 5.6.5 to 5.7.0. [GitHub Release Notes](https://github.com/sbt/sbt-header/releases/tag/v5.7.0) - [Version Diff](https://github.com/sbt/sbt-header/compare/v5.6.5...v5.7.0) I'll automatically update this PR to resolve conflicts as long as you don't change it yourself. If you'd...
### Short description In Akka persistence Cassandra, while we have a cleanup utility requiring specific persistent ids, it's cumbersome for large deployments. Setting a TTL upfront isn't always desired. Proposing...
