diff --git a/airbyte-cdk/java/airbyte-cdk/db-sources/src/main/kotlin/io/airbyte/cdk/integrations/debezium/internals/AirbyteFileOffsetBackingStore.kt b/airbyte-cdk/java/airbyte-cdk/db-sources/src/main/kotlin/io/airbyte/cdk/integrations/debezium/internals/AirbyteFileOffsetBackingStore.kt
index ee992781103c..3b985159b4fd 100644
--- a/airbyte-cdk/java/airbyte-cdk/db-sources/src/main/kotlin/io/airbyte/cdk/integrations/debezium/internals/AirbyteFileOffsetBackingStore.kt
+++ b/airbyte-cdk/java/airbyte-cdk/db-sources/src/main/kotlin/io/airbyte/cdk/integrations/debezium/internals/AirbyteFileOffsetBackingStore.kt
@@ -109,7 +109,7 @@ class AirbyteFileOffsetBackingStore(
         if (mapAsString.size > 0) {
             val key = mapAsString.keys.stream().toList()[0]
 
-            if (!key.contains("rs")) {
+            if (!key.contains("\"rs\":")) {
                 // The state is Debezium 2.6 compatible. No need to change anything.
                 return mapAsString
             }