diff --git a/eventual-cassandra/src/main/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/SnapshotStatements.scala b/eventual-cassandra/src/main/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/SnapshotStatements.scala index 0a4fb7846..93a260558 100644 --- a/eventual-cassandra/src/main/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/SnapshotStatements.scala +++ b/eventual-cassandra/src/main/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/SnapshotStatements.scala @@ -250,7 +250,7 @@ object SnapshotStatements { val bound = prepared .bind() .encode(key) - .encodeAt(3, bufferNr) + .encodeAt(2, bufferNr) .setConsistencyLevel(consistencyConfig.value) val rows = for {