From 4451d3df454b31a6e7a7b908d72eeee77ca88342 Mon Sep 17 00:00:00 2001 From: Ajit Date: Fri, 6 Sep 2024 01:35:05 +0530 Subject: [PATCH] DBZ-8202 extended support for mongoDb --- .../java/io/debezium/connector/mongodb/MongoUtils.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) 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"); }