Explicitly set batch type UNLOGGED (akka#827)

chbatey · Oct 12, 2020 · 6673fef · 6673fef
1 parent 68b2f21
commit 6673fef
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/core/src/main/scala/akka/persistence/cassandra/journal/CassandraJournal.scala b/core/src/main/scala/akka/persistence/cassandra/journal/CassandraJournal.scala
@@ -675,7 +675,7 @@ class CassandraJournal(cfg: Config)
   }
 
   private def executeBatch(body: BatchStatement => Unit, retryPolicy: RetryPolicy): Future[Unit] = {
-    val batch = new BatchStatement()
+    val batch = new BatchStatement(BatchStatement.Type.UNLOGGED)
       .setConsistencyLevel(writeConsistency)
       .setRetryPolicy(retryPolicy)
       .asInstanceOf[BatchStatement]

diff --git a/core/src/main/scala/akka/persistence/cassandra/snapshot/CassandraSnapshotStore.scala b/core/src/main/scala/akka/persistence/cassandra/snapshot/CassandraSnapshotStore.scala
@@ -255,7 +255,9 @@ class CassandraSnapshotStore(cfg: Config)
   }
 
   def executeBatch(body: BatchStatement => Unit): Future[Unit] = {
-    val batch = new BatchStatement().setConsistencyLevel(writeConsistency).asInstanceOf[BatchStatement]
+    val batch = new BatchStatement(BatchStatement.Type.UNLOGGED)
+      .setConsistencyLevel(writeConsistency)
+      .asInstanceOf[BatchStatement]
     body(batch)
     session.underlying().flatMap(_.executeAsync(batch)).map(_ => ())
   }