diff --git a/core/src/main/scala/akka/persistence/cassandra/journal/Buffer.scala b/core/src/main/scala/akka/persistence/cassandra/journal/Buffer.scala
index f3561f1e..07042f7a 100644
--- a/core/src/main/scala/akka/persistence/cassandra/journal/Buffer.scala
+++ b/core/src/main/scala/akka/persistence/cassandra/journal/Buffer.scala
@@ -107,7 +107,7 @@ private[akka] case class Buffer(
   }
 
   final def addPending(write: AwaitingWrite): Buffer = {
-    copy(size = size + write.events.size, pending = pending :+ write)
+    copy(size = size + write.events.size, pending = pending :+ write, writeRequired = true)
   }
 
   def writeComplete(): Buffer = {