From b2479704b534237934c9aef2c9001a790eed0be8 Mon Sep 17 00:00:00 2001 From: mfvitale Date: Wed, 20 Mar 2024 11:32:36 +0100 Subject: [PATCH] DBZ-7308 Adapt to core changes --- .../java/io/debezium/connector/db2/Db2ConnectorConfig.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/main/java/io/debezium/connector/db2/Db2ConnectorConfig.java b/src/main/java/io/debezium/connector/db2/Db2ConnectorConfig.java index 8e59cd6..d31604a 100644 --- a/src/main/java/io/debezium/connector/db2/Db2ConnectorConfig.java +++ b/src/main/java/io/debezium/connector/db2/Db2ConnectorConfig.java @@ -8,6 +8,7 @@ import java.util.Collections; import java.util.HashMap; import java.util.Map; +import java.util.Optional; import org.apache.kafka.common.config.ConfigDef; import org.apache.kafka.common.config.ConfigDef.Importance; @@ -404,8 +405,8 @@ public SnapshotIsolationMode getSnapshotIsolationMode() { return this.snapshotIsolationMode; } - public SnapshotLockingMode getSnapshotLockingMode() { - return this.snapshotLockingMode; + public Optional getSnapshotLockingMode() { + return Optional.of(this.snapshotLockingMode); } public SnapshotMode getSnapshotMode() {