diff --git a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/snapshot/MongoDbIncrementalSnapshotChangeEventSource.java b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/snapshot/MongoDbIncrementalSnapshotChangeEventSource.java
index ba9995ab2..c182568fe 100644
--- a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/snapshot/MongoDbIncrementalSnapshotChangeEventSource.java
+++ b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/snapshot/MongoDbIncrementalSnapshotChangeEventSource.java
@@ -636,7 +636,11 @@ private Document constructQueryPredicate(Object[] startKey, Object[] endKey, Str
 
     private String getAdditionalConditions() {
         // Strip additional parenthesis to make sure additional conditions are parsed correctly
-        return context.currentDataCollectionId().getAdditionalCondition().map(s -> s.substring(1, s.length() - 1)).orElse("");
+        return context.currentDataCollectionId().getAdditionalCondition().map(this::getStripedAdditionalConditions).orElse("");
+    }
+
+    private String getStripedAdditionalConditions(String additionalConditions) {
+        return additionalConditions.substring(1, additionalConditions.length() - 1);
     }
 
     private void incrementTableRowsScanned(long rows) {