diff --git a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/BinlogReader.java b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/BinlogReader.java
index 4f7cb1308..449f8ddaf 100644
--- a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/BinlogReader.java
+++ b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/BinlogReader.java
@@ -172,11 +172,6 @@ public boolean equals(Object obj) {
         }
     }
 
-    @FunctionalInterface
-    public static interface ParsingErrorHandler {
-        void error(String message, Exception exception);
-    }
-
     /**
      * Create a binlog reader.
      *
diff --git a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java
index 79b40d9c1..21336696b 100644
--- a/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java
+++ b/debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java
@@ -43,7 +43,6 @@
 import io.debezium.DebeziumException;
 import io.debezium.annotation.Immutable;
 import io.debezium.config.CommonConnectorConfig.BinaryHandlingMode;
-import io.debezium.connector.mysql.BinlogReader.ParsingErrorHandler;
 import io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser;
 import io.debezium.data.Json;
 import io.debezium.jdbc.JdbcValueConverters;
@@ -71,6 +70,11 @@
 @Immutable
 public class MySqlValueConverters extends JdbcValueConverters {
 
+    @FunctionalInterface
+    public static interface ParsingErrorHandler {
+        void error(String message, Exception exception);
+    }
+
     private static final Logger LOGGER = LoggerFactory.getLogger(MySqlValueConverters.class);
 
     /**