DBZ-7765 Add Partition parameter to validateLogPosition

debezium · Apr 11, 2024 · 1f32f1d · 1f32f1d
1 parent eb604ba
commit 1f32f1d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/io/debezium/connector/db2/Db2Connection.java b/src/main/java/io/debezium/connector/db2/Db2Connection.java
@@ -33,6 +33,7 @@
 import io.debezium.jdbc.JdbcConfiguration;
 import io.debezium.jdbc.JdbcConnection;
 import io.debezium.pipeline.spi.OffsetContext;
+import io.debezium.pipeline.spi.Partition;
 import io.debezium.relational.Column;
 import io.debezium.relational.ColumnEditor;
 import io.debezium.relational.Table;
@@ -565,7 +566,7 @@ public TableId createTableId(String databaseName, String schemaName, String tabl
         return new TableId(null, schemaName, tableName);
     }
 
-    public boolean validateLogPosition(OffsetContext offset, CommonConnectorConfig config) {
+    public boolean validateLogPosition(Partition partition, OffsetContext offset, CommonConnectorConfig config) {
 
         final Lsn storedLsn = ((Db2OffsetContext) offset).getChangePosition().getCommitLsn();