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() {