From 1b2be56b8b99afe7cc090511ac10da27477821c2 Mon Sep 17 00:00:00 2001 From: mfvitale Date: Wed, 10 Apr 2024 11:30:14 +0200 Subject: [PATCH] DBZ-7765 Add Partition parameter to validateLogPosition --- src/main/java/io/debezium/connector/db2/Db2Connection.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/io/debezium/connector/db2/Db2Connection.java b/src/main/java/io/debezium/connector/db2/Db2Connection.java index f2d473b..3e598c8 100644 --- 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();