From f7a1c6a6b3a21b0eb7cf7660e52952c24913d3b7 Mon Sep 17 00:00:00 2001
From: Tautvydas Januskevicius <tja@trustpilot.com>
Date: Fri, 23 Nov 2018 16:42:15 +0200
Subject: [PATCH] DBZ-848 Removed explicit primary node change handling. It is
 handled by mongoDb driver internally. Explicit primary node change event
 handling was causing issue that no mongo events were read after primary
 change. This issue only happened when rs.stepDown(<time s>) was used on mongo
 node.

---
 .../java/io/debezium/connector/mongodb/Replicator.java     | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Replicator.java b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Replicator.java
index ac8d5d450b0..8336dd4b4df 100644
--- a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Replicator.java
+++ b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/Replicator.java
@@ -452,10 +452,9 @@ protected boolean handleOplogEvent(ServerAddress primaryAddress, Document event)
                 ServerAddress serverAddress = address.get();
 
                 if (serverAddress != null && !serverAddress.equals(primaryAddress)) {
-                    logger.info("Found new primary event in oplog, so stopping use of {} to continue with new primary",
-                            primaryAddress);
-                    // There is a new primary, so stop using this server and instead use the new primary ...
-                    return false;
+                    //primary switch will be handled automatically by mongo driver.
+                    logger.info("Found new primary event in oplog, so stopping use of {} to continue with new primary {}",
+                            primaryAddress, serverAddress);
                 } else {
                     logger.info("Found new primary event in oplog, current {} is new primary. " +
                                 "Continue to process oplog event.", primaryAddress);