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

DBZ-401 Log binlog reader position in case of exception

Browse Source
This commit is contained in:
Jiri Pechanec 2017-11-02 05:54:01 +01:00 committed by Gunnar Morling
parent c1370556ff
commit 039566e717
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -333,6 +333,7 @@ protected void handleEvent(Event event) {
} catch (RuntimeException e) {
// There was an error in the event handler, so propagate the failure to Kafka Connect ...
logReaderState();
failed(e, "Error processing binlog event");
// Do not stop the client, since Kafka Connect should stop the connector on it's own
// (and doing it here may cause problems the second time it is stopped).
@ -708,6 +709,7 @@ public void onConnect(BinaryLogClient client) {
@Override
public void onCommunicationFailure(BinaryLogClient client, Exception ex) {
logger.debug("A communication failure event arrived", ex);
logReaderState();
try {
// Stop BinaryLogClient background threads
client.disconnect();
@ -721,7 +723,15 @@ public void onCommunicationFailure(BinaryLogClient client, Exception ex) {
@Override
public void onEventDeserializationFailure(BinaryLogClient client, Exception ex) {
logger.debug("A deserialization failure event arrived", ex);
logReaderState();
BinlogReader.this.failed(ex);
}
}
private void logReaderState() {
logger.error("Error during binlog processing. Last offset stored = {}, binlog reader near position = {}",
lastOffset,
client == null ? "N/A" : client.getBinlogFilename() + "/" + client.getBinlogPosition()
);
}
}