diff --git a/mysql-delta-plugins/src/main/java/io/debezium/connector/mysql/legacy/MySqlJdbcContext.java b/mysql-delta-plugins/src/main/java/io/debezium/connector/mysql/legacy/MySqlJdbcContext.java index 0a9e5b0..fe6c401 100644 --- a/mysql-delta-plugins/src/main/java/io/debezium/connector/mysql/legacy/MySqlJdbcContext.java +++ b/mysql-delta-plugins/src/main/java/io/debezium/connector/mysql/legacy/MySqlJdbcContext.java @@ -221,7 +221,7 @@ public boolean isGtidModeEnabled() { throw new ConnectException("Unexpected error while connecting to MySQL and looking at GTID mode: ", e); } - return !"OFF".equalsIgnoreCase(mode.get()); + return "ON".equalsIgnoreCase(mode.get()); } /**