DBZ-7717 LogPositionValidator is no more needed in Db2Connection

debezium · Mar 28, 2024 · 9d27719 · 9d27719
1 parent c3aa227
commit 9d27719
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/src/main/java/io/debezium/connector/db2/Db2Connection.java b/src/main/java/io/debezium/connector/db2/Db2Connection.java
@@ -116,7 +116,6 @@ public class Db2Connection extends JdbcConnection {
      */
     public Db2Connection(JdbcConfiguration config) {
         super(config, FACTORY, QUOTED_CHARACTER, QUOTED_CHARACTER);
-        this.logPositionValidator = this::validateLogPosition;
         lsnToInstantCache = new BoundedConcurrentHashMap<>(100);
         realDatabaseName = retrieveRealDatabaseName();
     }

diff --git a/src/main/java/io/debezium/connector/db2/Db2ConnectorTask.java b/src/main/java/io/debezium/connector/db2/Db2ConnectorTask.java
@@ -100,7 +100,7 @@ public ChangeEventSourceCoordinator<Db2Partition, Db2OffsetContext> start(Config
 
         final SnapshotterService snapshotterService = connectorConfig.getServiceRegistry().tryGetService(SnapshotterService.class);
 
-        validateAndLoadSchemaHistory(connectorConfig, metadataConnection, previousOffsets, schema,
+        validateAndLoadSchemaHistory(connectorConfig, metadataConnection::validateLogPosition, previousOffsets, schema,
                 snapshotterService.getSnapshotter());
 
         taskContext = new Db2TaskContext(connectorConfig, schema);