diff --git a/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlConnectorIT.java b/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlConnectorIT.java index 3149e9a22..5a405ef4b 100644 --- a/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlConnectorIT.java +++ b/debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/MySqlConnectorIT.java @@ -296,7 +296,7 @@ public void shouldValidateLockingModeNoneWithValidSnapshotModeConfiguration() { Config result = connector.validate(config.asMap()); assertNoConfigurationErrors(result, MySqlConnectorConfig.SNAPSHOT_LOCKING_MODE); - assertThat(new MySqlConnectorConfig(config).getSnapshotLockingMode()).isEqualTo(SnapshotLockingMode.NONE); + assertThat(new MySqlConnectorConfig(config).getSnapshotLockingMode().get()).isEqualTo(SnapshotLockingMode.NONE); } } diff --git a/debezium-core/src/main/java/io/debezium/snapshot/lock/NoLockingSupport.java b/debezium-core/src/main/java/io/debezium/snapshot/lock/NoLockingSupport.java index d6aab3c95..fcb2506a0 100644 --- a/debezium-core/src/main/java/io/debezium/snapshot/lock/NoLockingSupport.java +++ b/debezium-core/src/main/java/io/debezium/snapshot/lock/NoLockingSupport.java @@ -16,13 +16,13 @@ public class NoLockingSupport implements SnapshotLock { public static final String NO_LOCKING_SUPPORT = "no_locking_support"; @Override - public void configure(Map properties) { - + public String name() { + return NO_LOCKING_SUPPORT; } @Override - public String name() { - return NO_LOCKING_SUPPORT; + public void configure(Map properties) { + } @Override