DBZ-356 Making sure connection closing exception isn't swallowed

2017-09-19 11:49:34 +02:00 · 2017-09-19 11:49:34 +02:00 · 79fefa3cce
commit 79fefa3cce
parent abaf233066
1 changed files with 4 additions and 0 deletions
--- a/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/RecordsStreamProducer.java
+++ b/debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/RecordsStreamProducer.java
@ -191,6 +191,10 @@ private void closeConnections() {

                throw rethrown;
            }
+
+            if (closingException != null) {
+                throw new ConnectException(closingException);
+            }
        }
    }