diff --git a/core/src/main/java/io/debezium/connector/cassandra/CassandraOffsetContext.java b/core/src/main/java/io/debezium/connector/cassandra/CassandraOffsetContext.java
index 0e7d997..50af095 100644
--- a/core/src/main/java/io/debezium/connector/cassandra/CassandraOffsetContext.java
+++ b/core/src/main/java/io/debezium/connector/cassandra/CassandraOffsetContext.java
@@ -41,7 +41,7 @@ public Struct getSourceInfo() {
     }
 
     @Override
-    public boolean isSnapshotRunning() {
+    public boolean isInitialSnapshotRunning() {
         throw new UnsupportedOperationException();
     }