akka-persistence-cassandra
akka-persistence-cassandra copied to clipboard
A replicated Akka Persistence journal backed by Apache Cassandra
Scala version 3.3.0 Akka version: 2.8.3 ``` libraryDependencies ++= Seq( "com.typesafe.akka" %% "akka-serialization-jackson" % AkkaVersion, "com.typesafe.akka" %% "akka-persistence-cassandra" % "1.1.1", "com.typesafe.akka" %% "akka-persistence-typed" % AkkaVersion, "com.typesafe.akka" %% "akka-slf4j" % AkkaVersion,...
@johanandren Is there any way to assign custom dispatcher for specific sharded actor? I have found example for non sharded actor but not with sharded actor.
## About this PR 📦 Updates [org.scalatest:scalatest](https://github.com/scalatest/scalatest) from `3.2.18` to `3.2.19` ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve conflicts as long as you don't change...
Slow clean tagged events and overload Cassandra by overfetch insufficient data for deleteFromTagView
https://github.com/akka/akka-persistence-cassandra/blob/8006539934ff77bf72b1a8062a44478686112945/core/src/main/scala/akka/persistence/cassandra/reconciler/DeleteTagViewForPersistenceId.scala#L40 The problem is that when we try to clean events by tags, Cassandra Journal runs a stream with current events by tag and over fetch data by fetching event...
## About this PR 📦 Updates org.scala-lang:scala3-library from `3.3.1` to `3.3.3` ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve conflicts as long as you don't change...
## About this PR 📦 Updates [ch.qos.logback:logback-classic](https://github.com/qos-ch/logback) from `1.2.13` to `1.5.8` ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve conflicts as long as you don't change...