tighten rule for detecting pre 26 char

airbytehq · May 15, 2024 · 0fc2c18 · 0fc2c18
1 parent 877b3f8
commit 0fc2c18
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...in/kotlin/io/airbyte/cdk/integrations/debezium/internals/AirbyteFileOffsetBackingStore.kt b/...in/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
             }