modify sqlserver cdc

apache · Aug 21, 2023 · 3666c11 · 3666c11
1 parent 27f0bc2
commit 3666c11
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...atunnel/cdc/sqlserver/source/source/reader/fetch/scan/SqlServerSnapshotSplitReadTask.java b/...atunnel/cdc/sqlserver/source/source/reader/fetch/scan/SqlServerSnapshotSplitReadTask.java
@@ -31,6 +31,7 @@
 import io.debezium.connector.sqlserver.SqlServerDatabaseSchema;
 import io.debezium.connector.sqlserver.SqlServerOffsetContext;
 import io.debezium.pipeline.EventDispatcher;
+import io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics;
 import io.debezium.pipeline.source.AbstractSnapshotChangeEventSource;
 import io.debezium.pipeline.source.spi.ChangeEventSource;
 import io.debezium.pipeline.source.spi.SnapshotProgressListener;
@@ -159,7 +160,8 @@ protected AbstractSnapshotChangeEventSource.SnapshotContext prepare(
     private void createDataEvents(SqlSeverSnapshotContext snapshotContext, TableId tableId)
             throws Exception {
         EventDispatcher.SnapshotReceiver snapshotReceiver =
-                dispatcher.getSnapshotChangeEventReceiver();
+                dispatcher.getIncrementalSnapshotChangeEventReceiver(
+                        StreamingChangeEventSourceMetrics.NO_OP);
         log.debug("Snapshotting table {}", tableId);
         createDataEventsForTable(
                 snapshotContext, snapshotReceiver, databaseSchema.tableFor(tableId));