diff --git a/plugins/database/mongodb/connection_producer.go b/plugins/database/mongodb/connection_producer.go
index fbae8c4dcb..5915177020 100644
--- a/plugins/database/mongodb/connection_producer.go
+++ b/plugins/database/mongodb/connection_producer.go
@@ -132,8 +132,7 @@ func createClient(ctx context.Context, connURL string, clientOptions *options.Cl
 	clientOptions.SetSocketTimeout(1 * time.Minute)
 	clientOptions.SetConnectTimeout(1 * time.Minute)
 
-	opts := clientOptions.ApplyURI(connURL)
-	client, err = mongo.Connect(ctx, opts)
+	client, err = mongo.Connect(ctx, options.MergeClientOptions(options.Client().ApplyURI(connURL), clientOptions))
 	if err != nil {
 		return nil, err
 	}