Overview
了解如何使用连接统一资源标识符 (URI)将 MongoDB Kafka Connector 连接到 MongoDB。 连接 URI 是一个包含以下信息的string ：
所需MongoDB 部署的解决
连接设置可选
身份验证设置可选
身份验证凭证可选
以下是 MongoDB 副本集的连接 URI 示例：
mongodb://mongodb0.example.com:27017,mongodb1.example.com:27017,mongodb2.example.com:27017/?replicaSet=myRepl
要了解有关连接 URI 格式的更多信息，请参阅 stringMongoDB手册中的 连接 URI 格式 。
先决条件
要将MongoDB Kafka Connector连接到MongoDB，必须向数据库用户授予以下任一权限：
readWrite角色readAnyDatabase和clusterMonitor角色
如何连接
在源连接器和接收器connector中使用以下配置选项指定连接 URI：
connection.uri=<your connection uri>
要了解有关此配置选项的更多信息，请参阅以下资源：
如何配置连接
MongoDB Kafka Connector 使用MongoDB Java 驱动程序来解析您的连接 URI。 MongoDB Java 驱动程序是一个工件，它使 Kafka Connect 等 Java 应用程序能够与 MongoDB 交互。
重要
驱动程序版本
版本 2.1 的MongoDB Kafka Connector使用版本 4.7 的MongoDB Java驱动程序。
要学习 Connector 中可用的连接 URI 选项，请参阅 MongoDB Java 驱动程序连接指南。
身份验证
MongoDB Java 驱动程序中可用的所有身份验证机制在 MongoDB Kafka Connector 中都可用。
以下是使用SCRAM-SHA-256身份验证向 MongoDB 进行身份验证的连接 URI 示例：
mongodb://<db_username>:<db_password>@<hostname>:<port>/?authSource=<authenticationDb>&authMechanism=SCRAM-SHA-256
重要
加载密钥
为避免将身份验证密钥以纯文本形式存储在 connection.uri 设置中，请在Connector启动时从安全位置加载密钥。要学习；了解如何在Connector启动时加载密钥，请参阅 Confluent 的外部化密钥指南。
要学习可用的身份验证机制，请参阅MongoDB Java 驱动程序身份验证机制指南。
要了解有关connector中身份验证的更多信息，请参阅安全和身份验证指南。