Certify mongodb plugin (#3115)

* fix(mongodb): use "majority" as the default write concern

The current default, an empty string, causes an error when the output is
used:
```
Failed to send message to mongodb: (BadValue) cannot use non-majority 'w' mode "" when a host is not a member of a replica set
```

This commit changes the default to "majority" which the MongoDB docs
describe as ["the default write concern for most MongoDB
deployments"](https://www.mongodb.com/docs/manual/reference/write-concern/#w-option).

* feat(mongodb): certify plugin

Author: ooesili

docs/modules/components/pages/outputs/mongodb.adoc

@@ -46,7 +46,7 @@ output:
     collection: "" # No default (required)
     operation: update-one
     write_concern:
-      w: ""
+      w: majority
       j: false
       w_timeout: ""
     document_map: ""
@@ -79,7 +79,7 @@ output:
     collection: "" # No default (required)
     operation: update-one
     write_concern:
-      w: ""
+      w: majority
       j: false
       w_timeout: ""
     document_map: ""
@@ -197,12 +197,12 @@ The write concern settings for the mongo connection.
 
 === `write_concern.w`
 
-W requests acknowledgement that write operations propagate to the specified number of mongodb instances.
+W requests acknowledgement that write operations propagate to the specified number of mongodb instances. Can be the string "majority" to wait for a calculated majority of nodes to acknowledge the write operation, or an integer value specifying an minimum number of nodes to acknowledge the operation, or a string specifying the name of a custom write concern configured in the cluster.
 
 
 *Type*: `string`
 
-*Default*: `""`
+*Default*: `"majority"`
 
 === `write_concern.j`
 

docs/modules/components/pages/processors/mongodb.adoc

@@ -45,7 +45,7 @@ mongodb:
   collection: "" # No default (required)
   operation: insert-one
   write_concern:
-    w: ""
+    w: majority
     j: false
     w_timeout: ""
   document_map: ""
@@ -71,7 +71,7 @@ mongodb:
   collection: "" # No default (required)
   operation: insert-one
   write_concern:
-    w: ""
+    w: majority
     j: false
     w_timeout: ""
   document_map: ""
@@ -176,12 +176,12 @@ The write concern settings for the mongo connection.
 
 === `write_concern.w`
 
-W requests acknowledgement that write operations propagate to the specified number of mongodb instances.
+W requests acknowledgement that write operations propagate to the specified number of mongodb instances. Can be the string "majority" to wait for a calculated majority of nodes to acknowledge the write operation, or an integer value specifying an minimum number of nodes to acknowledge the operation, or a string specifying the name of a custom write concern configured in the cluster.
 
 
 *Type*: `string`
 
-*Default*: `""`
+*Default*: `"majority"`
 
 === `write_concern.j`
 

internal/impl/mongodb/common.go

@@ -260,8 +260,8 @@ const (
 func writeConcernDocs() *service.ConfigField {
 	return service.NewObjectField(commonFieldWriteConcern,
 		service.NewStringField(commonFieldWriteConcernW).
-			Description("W requests acknowledgement that write operations propagate to the specified number of mongodb instances.").
-			Default(""),
+			Description(`W requests acknowledgement that write operations propagate to the specified number of mongodb instances. Can be the string "majority" to wait for a calculated majority of nodes to acknowledge the write operation, or an integer value specifying an minimum number of nodes to acknowledge the operation, or a string specifying the name of a custom write concern configured in the cluster.`).
+			Default("majority"),
 		service.NewBoolField(commonFieldWriteConcernJ).
 			Description("J requests acknowledgement from MongoDB that write operations are written to the journal.").
 			Default(false),

internal/impl/mongodb/processor.go

@@ -30,7 +30,6 @@ import (
 
 const (
 	mpFieldCollection      = "collection"
-	mpFieldWriteConcern    = "write_concern"
 	mpFieldJSONMarshalMode = "json_marshal_mode"
 )
 

internal/plugins/info.csv

@@ -122,10 +122,10 @@ memcached                 ,cache     ,Memcached                 ,0.0.0   ,commun
 memory                    ,buffer    ,Memory                    ,0.0.0   ,certified  ,n          ,y     ,y
 memory                    ,cache     ,Memory                    ,0.0.0   ,certified  ,n          ,y     ,y
 metric                    ,processor ,metric                    ,0.0.0   ,certified  ,n          ,y     ,y
-mongodb                   ,cache     ,MongoDB                   ,3.43.0  ,community  ,n          ,n     ,n
-mongodb                   ,input     ,MongoDB                   ,3.64.0  ,community  ,n          ,n     ,n
-mongodb                   ,output    ,MongoDB                   ,3.43.0  ,community  ,n          ,n     ,n
-mongodb                   ,processor ,MongoDB                   ,3.43.0  ,community  ,n          ,n     ,n
+mongodb                   ,cache     ,MongoDB                   ,3.43.0  ,certified  ,n          ,y     ,y
+mongodb                   ,input     ,MongoDB                   ,3.64.0  ,certified  ,n          ,y     ,y
+mongodb                   ,output    ,MongoDB                   ,3.43.0  ,certified  ,n          ,y     ,y
+mongodb                   ,processor ,MongoDB                   ,3.43.0  ,certified  ,n          ,y     ,y
 mqtt                      ,input     ,mqtt                      ,4.37.0  ,certified  ,n          ,y     ,y
 mqtt                      ,output    ,mqtt                      ,4.37.0  ,certified  ,n          ,y     ,y
 msgpack                   ,processor ,msgpack                   ,3.59.0  ,community  ,n          ,n     ,n

public/components/cloud/package.go

@@ -29,6 +29,7 @@ import (
 	_ "github.com/redpanda-data/connect/v4/public/components/kafka/enterprise"
 	_ "github.com/redpanda-data/connect/v4/public/components/maxmind"
 	_ "github.com/redpanda-data/connect/v4/public/components/memcached"
+	_ "github.com/redpanda-data/connect/v4/public/components/mongodb"
 	_ "github.com/redpanda-data/connect/v4/public/components/mqtt"
 	_ "github.com/redpanda-data/connect/v4/public/components/msgpack"
 	_ "github.com/redpanda-data/connect/v4/public/components/mysql"