[2022-07-26 09:36:27,633] ERROR [mongodb-jsondb-connector|task-0] Error while attempting to read from oplog on 'globaldb/sit-mongodb.mongo.cosmos.azure.com:10255': Command failed with error 2 (BadValue): 'Expected type string but found int.' on server sit-mongodb.mongo.cosmos.azure.com:10255. The full response is {"ok": 0.0, "errmsg": "Expected type string but found int.", "code": 2, "codeName": "BadValue"} (io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource:181) com.mongodb.MongoCommandException: Command failed with error 2 (BadValue): 'Expected type string but found int.' on server sit-mongodb.mongo.cosmos.azure.com:10255. The full response is {"ok": 0.0, "errmsg": "Expected type string but found int.", "code": 2, "codeName": "BadValue"} at com.mongodb.internal.connection.ProtocolHelper.getCommandFailureException(ProtocolHelper.java:195) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:400) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:324) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:114) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:603) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:81) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:252) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:214) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:123) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:113) at com.mongodb.internal.operation.CommandOperationHelper.executeCommand(CommandOperationHelper.java:328) at com.mongodb.internal.operation.CommandOperationHelper.executeCommand(CommandOperationHelper.java:318) at com.mongodb.internal.operation.CommandOperationHelper.executeCommandWithConnection(CommandOperationHelper.java:201) at com.mongodb.internal.operation.CommandOperationHelper.lambda$executeCommand$4(CommandOperationHelper.java:189) at com.mongodb.internal.operation.OperationHelper.withReadConnectionSource(OperationHelper.java:583) at com.mongodb.internal.operation.CommandOperationHelper.executeCommand(CommandOperationHelper.java:189) at com.mongodb.internal.operation.AggregateOperationImpl.execute(AggregateOperationImpl.java:195) at com.mongodb.internal.operation.ChangeStreamOperation$1.call(ChangeStreamOperation.java:323) at com.mongodb.internal.operation.ChangeStreamOperation$1.call(ChangeStreamOperation.java:319) at com.mongodb.internal.operation.OperationHelper.withReadConnectionSource(OperationHelper.java:583) at com.mongodb.internal.operation.ChangeStreamOperation.execute(ChangeStreamOperation.java:319) at com.mongodb.internal.operation.ChangeStreamOperation.execute(ChangeStreamOperation.java:58) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:184) at com.mongodb.client.internal.ChangeStreamIterableImpl.execute(ChangeStreamIterableImpl.java:204) at com.mongodb.client.internal.ChangeStreamIterableImpl.cursor(ChangeStreamIterableImpl.java:158) at com.mongodb.client.internal.ChangeStreamIterableImpl.iterator(ChangeStreamIterableImpl.java:153) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.readChangeStream(MongoDbStreamingChangeEventSource.java:332) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.lambda$streamChangesForReplicaSet$0(MongoDbStreamingChangeEventSource.java:124) at io.debezium.connector.mongodb.ConnectionContext$MongoPrimary.execute(ConnectionContext.java:288) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.streamChangesForReplicaSet(MongoDbStreamingChangeEventSource.java:122) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.execute(MongoDbStreamingChangeEventSource.java:103) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.execute(MongoDbStreamingChangeEventSource.java:59) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) [2022-07-26 09:36:27,639] ERROR [mongodb-jsondb-connector|task-0] Streaming for replica set globaldb failed (io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource:133) org.apache.kafka.connect.errors.ConnectException: Error while attempting to read from oplog on 'globaldb/sit-mongodb.mongo.cosmos.azure.com:10255' at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.lambda$establishConnectionToPrimary$3(MongoDbStreamingChangeEventSource.java:182) at io.debezium.connector.mongodb.ConnectionContext$MongoPrimary.execute(ConnectionContext.java:292) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.streamChangesForReplicaSet(MongoDbStreamingChangeEventSource.java:122) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.execute(MongoDbStreamingChangeEventSource.java:103) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.execute(MongoDbStreamingChangeEventSource.java:59) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: com.mongodb.MongoCommandException: Command failed with error 2 (BadValue): 'Expected type string but found int.' on server sit-mongodb.mongo.cosmos.azure.com:10255. The full response is {"ok": 0.0, "errmsg": "Expected type string but found int.", "code": 2, "codeName": "BadValue"} at com.mongodb.internal.connection.ProtocolHelper.getCommandFailureException(ProtocolHelper.java:195) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:400) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:324) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:114) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:603) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:81) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:252) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:214) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:123) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:113) at com.mongodb.internal.operation.CommandOperationHelper.executeCommand(CommandOperationHelper.java:328) at com.mongodb.internal.operation.CommandOperationHelper.executeCommand(CommandOperationHelper.java:318) at com.mongodb.internal.operation.CommandOperationHelper.executeCommandWithConnection(CommandOperationHelper.java:201) at com.mongodb.internal.operation.CommandOperationHelper.lambda$executeCommand$4(CommandOperationHelper.java:189) at com.mongodb.internal.operation.OperationHelper.withReadConnectionSource(OperationHelper.java:583) at com.mongodb.internal.operation.CommandOperationHelper.executeCommand(CommandOperationHelper.java:189) at com.mongodb.internal.operation.AggregateOperationImpl.execute(AggregateOperationImpl.java:195) at com.mongodb.internal.operation.ChangeStreamOperation$1.call(ChangeStreamOperation.java:323) at com.mongodb.internal.operation.ChangeStreamOperation$1.call(ChangeStreamOperation.java:319) at com.mongodb.internal.operation.OperationHelper.withReadConnectionSource(OperationHelper.java:583) at com.mongodb.internal.operation.ChangeStreamOperation.execute(ChangeStreamOperation.java:319) at com.mongodb.internal.operation.ChangeStreamOperation.execute(ChangeStreamOperation.java:58) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:184) at com.mongodb.client.internal.ChangeStreamIterableImpl.execute(ChangeStreamIterableImpl.java:204) at com.mongodb.client.internal.ChangeStreamIterableImpl.cursor(ChangeStreamIterableImpl.java:158) at com.mongodb.client.internal.ChangeStreamIterableImpl.iterator(ChangeStreamIterableImpl.java:153) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.readChangeStream(MongoDbStreamingChangeEventSource.java:332) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.lambda$streamChangesForReplicaSet$0(MongoDbStreamingChangeEventSource.java:124) at io.debezium.connector.mongodb.ConnectionContext$MongoPrimary.execute(ConnectionContext.java:288) ... 11 more [2022-07-26 09:36:27,645] ERROR [mongodb-jsondb-connector|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:35) org.apache.kafka.connect.errors.ConnectException: Error while attempting to read from oplog on 'globaldb/sit-mongodb.mongo.cosmos.azure.com:10255' at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.lambda$establishConnectionToPrimary$3(MongoDbStreamingChangeEventSource.java:182) at io.debezium.connector.mongodb.ConnectionContext$MongoPrimary.execute(ConnectionContext.java:292) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.streamChangesForReplicaSet(MongoDbStreamingChangeEventSource.java:122) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.execute(MongoDbStreamingChangeEventSource.java:103) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.execute(MongoDbStreamingChangeEventSource.java:59) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: com.mongodb.MongoCommandException: Command failed with error 2 (BadValue): 'Expected type string but found int.' on server sit-mongodb.mongo.cosmos.azure.com:10255. The full response is {"ok": 0.0, "errmsg": "Expected type string but found int.", "code": 2, "codeName": "BadValue"} at com.mongodb.internal.connection.ProtocolHelper.getCommandFailureException(ProtocolHelper.java:195) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:400) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:324) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:114) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:603) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:81) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:252) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:214) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:123) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:113) at com.mongodb.internal.operation.CommandOperationHelper.executeCommand(CommandOperationHelper.java:328) at com.mongodb.internal.operation.CommandOperationHelper.executeCommand(CommandOperationHelper.java:318) at com.mongodb.internal.operation.CommandOperationHelper.executeCommandWithConnection(CommandOperationHelper.java:201) at com.mongodb.internal.operation.CommandOperationHelper.lambda$executeCommand$4(CommandOperationHelper.java:189) at com.mongodb.internal.operation.OperationHelper.withReadConnectionSource(OperationHelper.java:583) at com.mongodb.internal.operation.CommandOperationHelper.executeCommand(CommandOperationHelper.java:189) at com.mongodb.internal.operation.AggregateOperationImpl.execute(AggregateOperationImpl.java:195) at com.mongodb.internal.operation.ChangeStreamOperation$1.call(ChangeStreamOperation.java:323) at com.mongodb.internal.operation.ChangeStreamOperation$1.call(ChangeStreamOperation.java:319) at com.mongodb.internal.operation.OperationHelper.withReadConnectionSource(OperationHelper.java:583) at com.mongodb.internal.operation.ChangeStreamOperation.execute(ChangeStreamOperation.java:319) at com.mongodb.internal.operation.ChangeStreamOperation.execute(ChangeStreamOperation.java:58) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:184) at com.mongodb.client.internal.ChangeStreamIterableImpl.execute(ChangeStreamIterableImpl.java:204) at com.mongodb.client.internal.ChangeStreamIterableImpl.cursor(ChangeStreamIterableImpl.java:158) at com.mongodb.client.internal.ChangeStreamIterableImpl.iterator(ChangeStreamIterableImpl.java:153) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.readChangeStream(MongoDbStreamingChangeEventSource.java:332) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.lambda$streamChangesForReplicaSet$0(MongoDbStreamingChangeEventSource.java:124) at io.debezium.connector.mongodb.ConnectionContext$MongoPrimary.execute(ConnectionContext.java:288) ... 11 more [2022-07-26 09:36:27,648] INFO [mongodb-jsondb-connector|task-0] Closing all connections to globaldb/sit-mongodb.mongo.cosmos.azure.com:10255 (io.debezium.connector.mongodb.ConnectionContext:100) [2022-07-26 09:36:27,699] ERROR [mongodb-jsondb-connector|task-0] WorkerSourceTask{id=mongodb-jsondb-connector-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:195) org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:50) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.streamChangesForReplicaSet(MongoDbStreamingChangeEventSource.java:134) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.execute(MongoDbStreamingChangeEventSource.java:103) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.execute(MongoDbStreamingChangeEventSource.java:59) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174) at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: org.apache.kafka.connect.errors.ConnectException: Error while attempting to read from oplog on 'globaldb/sit-mongodb.mongo.cosmos.azure.com:10255' at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.lambda$establishConnectionToPrimary$3(MongoDbStreamingChangeEventSource.java:182) at io.debezium.connector.mongodb.ConnectionContext$MongoPrimary.execute(ConnectionContext.java:292) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.streamChangesForReplicaSet(MongoDbStreamingChangeEventSource.java:122) ... 10 more Caused by: com.mongodb.MongoCommandException: Command failed with error 2 (BadValue): 'Expected type string but found int.' on server sit-mongodb.mongo.cosmos.azure.com:10255. The full response is {"ok": 0.0, "errmsg": "Expected type string but found int.", "code": 2, "codeName": "BadValue"} at com.mongodb.internal.connection.ProtocolHelper.getCommandFailureException(ProtocolHelper.java:195) at com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:400) at com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:324) at com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:114) at com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:603) at com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:81) at com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:252) at com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:214) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:123) at com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:113) at com.mongodb.internal.operation.CommandOperationHelper.executeCommand(CommandOperationHelper.java:328) at com.mongodb.internal.operation.CommandOperationHelper.executeCommand(CommandOperationHelper.java:318) at com.mongodb.internal.operation.CommandOperationHelper.executeCommandWithConnection(CommandOperationHelper.java:201) at com.mongodb.internal.operation.CommandOperationHelper.lambda$executeCommand$4(CommandOperationHelper.java:189) at com.mongodb.internal.operation.OperationHelper.withReadConnectionSource(OperationHelper.java:583) at com.mongodb.internal.operation.CommandOperationHelper.executeCommand(CommandOperationHelper.java:189) at com.mongodb.internal.operation.AggregateOperationImpl.execute(AggregateOperationImpl.java:195) at com.mongodb.internal.operation.ChangeStreamOperation$1.call(ChangeStreamOperation.java:323) at com.mongodb.internal.operation.ChangeStreamOperation$1.call(ChangeStreamOperation.java:319) at com.mongodb.internal.operation.OperationHelper.withReadConnectionSource(OperationHelper.java:583) at com.mongodb.internal.operation.ChangeStreamOperation.execute(ChangeStreamOperation.java:319) at com.mongodb.internal.operation.ChangeStreamOperation.execute(ChangeStreamOperation.java:58) at com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:184) at com.mongodb.client.internal.ChangeStreamIterableImpl.execute(ChangeStreamIterableImpl.java:204) at com.mongodb.client.internal.ChangeStreamIterableImpl.cursor(ChangeStreamIterableImpl.java:158) at com.mongodb.client.internal.ChangeStreamIterableImpl.iterator(ChangeStreamIterableImpl.java:153) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.readChangeStream(MongoDbStreamingChangeEventSource.java:332) at io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.lambda$streamChangesForReplicaSet$0(MongoDbStreamingChangeEventSource.java:124) at io.debezium.connector.mongodb.ConnectionContext$MongoPrimary.execute(ConnectionContext.java:288) ... 11 more [2022-07-26 09:36:27,701] INFO [mongodb-jsondb-connector|task-0] Stopping down connector (io.debezium.connector.common.BaseSourceTask:238) [2022-07-26 09:36:27,788] INFO [mongodb-jsondb-connector|task-0] Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:175) [2022-07-26 09:36:27,790] INFO [mongodb-jsondb-connector|task-0] Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator:236) [2022-07-26 09:36:27,792] INFO [mongodb-jsondb-connector|task-0] [Producer clientId=connector-producer-mongodb-jsondb-connector-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1249) [2022-07-26 09:36:27,796] INFO [mongodb-jsondb-connector|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2022-07-26 09:36:27,797] INFO [mongodb-jsondb-connector|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2022-07-26 09:36:27,797] INFO [mongodb-jsondb-connector|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2022-07-26 09:36:27,797] INFO [mongodb-jsondb-connector|task-0] App info kafka.producer for connector-producer-mongodb-jsondb-connector-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2022-07-26 09:36:46,961] INFO [mongodb-jsondb-connector|worker] Checking current members of replica set at sit-mongodb.mongo.cosmos.azure.com:10255 (io.debezium.connector.mongodb.ReplicaSetDiscovery:91) [2022-07-26 09:36:52,301] INFO [AdminClient clientId=adminclient-8] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:935) [2022-07-26 09:37:16,944] INFO [mongodb-jsondb-connector|worker] Checking current members of replica set at sit-mongodb.mongo.cosmos.azure.com:10255 (io.debezium.connector.mongodb.ReplicaSetDiscovery:91)