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

DBZ-178: Correcting error where error message is only logged in success scenarios in EmbeddedEngine

Browse Source
This commit is contained in:
Ramesh Reddy 2017-01-11 09:39:47 -06:00
parent 49e6231b69
commit 29a7043fe3
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngine.java
View File

@ -464,7 +464,7 @@ private EmbeddedEngine(Configuration config, ClassLoader classLoader, Clock cloc
this.classLoader = classLoader;
this.clock = clock;
this.completionCallback = completionCallback != null ? completionCallback : (success, msg, error) -> {
if (success) logger.error(msg, error);
if (!success) logger.error(msg, error);
};
this.connectorCallback = connectorCallback;
this.completionResult = new CompletionResult();