diff --git a/akka-persistence/akka-persistence-cassandra/src/main/scala/CassandraStorageBackend.scala b/akka-persistence/akka-persistence-cassandra/src/main/scala/CassandraStorageBackend.scala
index 420ca88429..b67a0e9256 100644
--- a/akka-persistence/akka-persistence-cassandra/src/main/scala/CassandraStorageBackend.scala
+++ b/akka-persistence/akka-persistence-cassandra/src/main/scala/CassandraStorageBackend.scala
@@ -105,10 +105,9 @@ private[akka] object CassandraStorageBackend extends
     }
   }
 
-  def insertVectorStorageEntriesFor(name: String, elements: List[Array[Byte]]) = {
-    throw new UnsupportedOperationException("CassandraStorageBackend::insertVectorStorageEntriesFor is not implemented")
-  }
-
+  def insertVectorStorageEntriesFor(name: String, elements: List[Array[Byte]]) = 
+    elements.foreach(insertVectorStorageEntryFor(name, _))
+  
   def updateVectorStorageEntryFor(name: String, index: Int, elem: Array[Byte]) = {
     val columnPath = new ColumnPath(VECTOR_COLUMN_PARENT.getColumn_family)
     columnPath.setColumn(intToBytes(index))
diff --git a/akka-samples/akka-sample-rest-java/src/main/java/sample/rest/java/PersistentSimpleService.java b/akka-samples/akka-sample-rest-java/src/main/java/sample/rest/java/PersistentSimpleService.java
index 2a2abf2443..82d4bc5ea5 100644
--- a/akka-samples/akka-sample-rest-java/src/main/java/sample/rest/java/PersistentSimpleService.java
+++ b/akka-samples/akka-sample-rest-java/src/main/java/sample/rest/java/PersistentSimpleService.java
@@ -36,7 +36,7 @@ public class PersistentSimpleService {
   public String count() {
     if (storage == null) storage = CassandraStorage.newMap();
     if (!hasStartedTicking) {
-      storage.put(KEY.getBytes(), ByteBuffer.allocate(2).putInt(0).array());
+      storage.put(KEY.getBytes(), ByteBuffer.allocate(4).putInt(0).array());
       hasStartedTicking = true;
       return "Tick: 0\n";
     } else {