DBZ-7717 LogPositionValidator is no more needed in Db2Connection

debezium · Apr 5, 2024 · 791633f · 791633f
1 parent 016a78e
commit 791633f
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);