From 2779c6b05b8f950c8031338e6ce66dc28024140b Mon Sep 17 00:00:00 2001 From: mfvitale Date: Wed, 20 Mar 2024 11:29:06 +0100 Subject: [PATCH] DBZ-7308 Adapt to core changes --- .../io/debezium/connector/vitess/VitessConnectorConfig.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/main/java/io/debezium/connector/vitess/VitessConnectorConfig.java b/src/main/java/io/debezium/connector/vitess/VitessConnectorConfig.java index 37a7ef2a..80bc84fc 100644 --- a/src/main/java/io/debezium/connector/vitess/VitessConnectorConfig.java +++ b/src/main/java/io/debezium/connector/vitess/VitessConnectorConfig.java @@ -13,6 +13,7 @@ import java.util.HashSet; import java.util.List; import java.util.Map; +import java.util.Optional; import java.util.Set; import java.util.stream.Collectors; @@ -613,6 +614,11 @@ public SnapshotMode getSnapshotMode() { return SnapshotMode.parse(getConfig().getString(SNAPSHOT_MODE), SNAPSHOT_MODE.defaultValueAsString()); } + @Override + public Optional getSnapshotLockingMode() { + return Optional.empty(); + } + public BigIntUnsignedHandlingMode getBigIntUnsgnedHandlingMode() { return BigIntUnsignedHandlingMode.parse(getConfig().getString(BIGINT_UNSIGNED_HANDLING_MODE), BIGINT_UNSIGNED_HANDLING_MODE.defaultValueAsString());