Merge pull request #141 from data-integrations/fix/snapshot-handling

Correctly mark record if it is part of snapshot or not for mysql.

Author: sagarkapare

mysql-delta-plugins/src/main/java/io/cdap/delta/mysql/MySqlRecordConsumer.java

@@ -126,7 +126,7 @@ public void accept(SourceRecord sourceRecord) {
       // This should not happen, 'source' is a mandatory field in sourceRecord from debezium
       return;
     }
-    boolean isSnapshot = Boolean.TRUE.equals(deltaOffset.get(MySqlConstantOffsetBackingStore.SNAPSHOT));
+    boolean isSnapshot = Boolean.parseBoolean(deltaOffset.get(MySqlConstantOffsetBackingStore.SNAPSHOT));
     // If the map is empty, we should read all DDL/DML events and columns of all tables
     boolean readAllTables = sourceTableMap.isEmpty();
 

sqlserver-delta-plugins/src/main/java/io/cdap/delta/sqlserver/SqlServerOffset.java

@@ -48,7 +48,7 @@ public class SqlServerOffset {
   }
 
   boolean isSnapshot() {
-    return Boolean.TRUE.equals(isSnapshot);
+    return isSnapshot;
   }
 
   void setSnapshotTables(Set<String> snapshotTables) {