diff --git a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/ConnectionContext.java b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/ConnectionContext.java
index 274c98150..3e205bd97 100644
--- a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/ConnectionContext.java
+++ b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/ConnectionContext.java
@@ -223,7 +223,7 @@ public static class MongoPrimary {
         private final Supplier<MongoClient> primaryConnectionSupplier;
         private final Filters filters;
         private final BiConsumer<String, Throwable> errorHandler;
-        private final AtomicBoolean stop = new AtomicBoolean();
+        private final AtomicBoolean stopped = new AtomicBoolean();
 
         protected MongoPrimary(ConnectionContext context, ReplicaSet replicaSet, Filters filters, BiConsumer<String, Throwable> errorHandler) {
             this.replicaSet = replicaSet;
@@ -399,14 +399,14 @@ public List<CollectionId> collections() {
         }
 
         private boolean isRunning() {
-            return stop.get();
+            return stopped.get();
         }
 
         /**
          * Terminates the execution loop of the current primary
          */
         public void stop() {
-            stop.set(true);
+            stopped.set(true);
         }
     }