DBZ-7765 Add Partition parameter to validateLogPosition

debezium · Apr 11, 2024 · d1665d7 · d1665d7
1 parent 11ec92b
commit d1665d7
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/io/debezium/connector/informix/InformixConnection.java b/src/main/java/io/debezium/connector/informix/InformixConnection.java
@@ -27,6 +27,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.Table;
 import io.debezium.relational.TableEditor;
 import io.debezium.relational.TableId;
@@ -227,7 +228,7 @@ public boolean isWrapperFor(Class<?> iface) throws SQLException {
         };
     }
 
-    public boolean validateLogPosition(OffsetContext offset, CommonConnectorConfig config) {
+    public boolean validateLogPosition(Partition partition, OffsetContext offset, CommonConnectorConfig config) {
 
         final Lsn storedLsn = ((InformixOffsetContext) offset).getChangePosition().getCommitLsn();