diff --git a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbErrorHandler.java b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbErrorHandler.java index 05d1ad7f7..c2a80de54 100644 --- a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbErrorHandler.java +++ b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbErrorHandler.java @@ -26,8 +26,7 @@ protected boolean isRetriable(Throwable throwable) { while ((cause != null) && (cause != throwable)) { if (cause instanceof com.mongodb.MongoSocketException) { return true; - } - else { + } else { cause = cause.getCause(); } }