连接到 MongoDB
概述
学习如何使用连接统一资源标识符（URI）将 MongoDB Kafka 连接器连接到 MongoDB。连接 URI 是一个包含以下信息的字符串
您的 MongoDB 部署的地址 必需
连接设置 可选
身份验证设置 可选
身份验证凭证 可选
以下是一个 MongoDB 副本集的连接 URI 示例
mongodb://mongodb0.example.com:27017,mongodb1.example.com:27017,mongodb2.example.com:27017/?replicaSet=myRepl
有关连接 URI 格式的更多信息，请参阅连接字符串 URI 格式，MongoDB 手册。
如何连接
在源连接器和目标连接器中使用以下配置选项指定连接 URI
connection.uri=<your connection uri>
有关此配置选项的更多信息，请参阅以下资源
如何配置您的连接
MongoDB Kafka Connector 使用 MongoDB Java 驱动程序 解析您的连接 URI。MongoDB Java 驱动程序是一个使 Kafka Connect 等Java应用程序能够与 MongoDB 交互的组件。
重要
驱动程序版本
MongoDB Kafka Connector 的 1.14 版本使用 MongoDB Java 驱动程序的 4.7 版本。
要了解连接器中可用的连接 URI 选项，请参阅 MongoDB Java 驱动程序连接指南。
身份验证
MongoDB Kafka Connector 中提供了 MongoDB Java 驱动程序中所有的身份验证机制。
以下是一个使用 SCRAM-SHA-256 身份验证与 MongoDB 进行身份验证的连接 URI 的示例SCRAM-SHA-256 身份验证
mongodb://<db_username>:<db_password>@<hostname>:<port>/?authSource=<authenticationDb>&authMechanism=SCRAM-SHA-256
重要
加载密钥
为了避免将您的身份验证密钥以明文形式存储在 connection.uri 设置中，请在连接器启动时从安全位置加载您的密钥。有关如何连接器启动时加载您的密钥的说明，请参阅 Confluent 的外部化密钥指南。
要了解可用的身份验证机制，请参阅MongoDB Java驱动程序身份验证机制指南。
要了解更多关于连接器中的身份验证信息，请参阅安全性和身份验证指南。