diff --git a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoUtils.java b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoUtils.java index 65526bfd2..85a6f9bed 100644 --- a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoUtils.java +++ b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoUtils.java @@ -16,6 +16,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import com.mongodb.MongoException; import com.mongodb.client.ChangeStreamIterable; import com.mongodb.client.MongoClient; import com.mongodb.client.MongoCollection; @@ -235,7 +236,14 @@ public static ChangeStreamIterable openChangeStream(MongoClient cl public static BsonTimestamp hello(MongoClient client, String dbName) { var database = client.getDatabase(dbName); - var result = database.runCommand(new Document("hello", 1), BsonDocument.class); + BsonDocument result; + try { + result = database.runCommand(new Document("hello", 1), BsonDocument.class); + } + catch (MongoException e) { + LOGGER.error(e.getMessage(), e); + result = database.runCommand(new Document("isMaster", 1), BsonDocument.class); + } return result.getTimestamp("operationTime"); }