diff --git a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbConnectorTask.java b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbConnectorTask.java
index 026f90074..870f9ff53 100644
--- a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbConnectorTask.java
+++ b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbConnectorTask.java
@@ -154,7 +154,7 @@ public void start(Configuration config) {
     @Override
     public List<SourceRecord> poll() throws InterruptedException {
         if (replicatorError != null) {
-            throw new ConnectException("Failing connector task, at least one of the replicators has failed");
+            throw new ConnectException("Failing connector task, at least one of the replicators has failed", replicatorError);
         }
         List<SourceRecord> records = queue.poll();
         recordSummarizer.accept(records);