The official MongoDB Kafka Connect Sink connector.
readWrite
role on the database. For more granular access control, you can specify a custom role that allows insert
, remove
, and update
actions on the databases or collections.connection.uri
is in form of mongodb+srv://username:password@cluster0.xxx.mongodb.net
STRING
or BYTES
as the value converter for both MongoDB source and MongoDB sink connectors. Details can be found here.
Parameter | Description |
---|---|
connection.uri | The connection URI for the MongoDB server. |
database | The MongoDB database name. |
topics | A list of Kafka topics that the sink connector watches. (You can define either the topics or the topics.regex setting, but not both.) |
topics.regex | A regular expression that matches the Kafka topics that the sink connector watches. (You can define either the topics or the topics.regex setting, but not both.) |