alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-2563 Avoiding dependency from MySqlValueConverters to BinlogReader

Browse Source
This commit is contained in:
Gunnar Morling 2020-09-29 10:33:18 +02:00
parent 87d70cb96d
commit 3d12616627
2 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/BinlogReader.java
View File

@ -172,11 +172,6 @@ public boolean equals(Object obj) {
}
}
@FunctionalInterface
public static interface ParsingErrorHandler {
void error(String message, Exception exception);
}
/**
* Create a binlog reader.
*

6
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java
View File

@ -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);
/**