连接至 MongoDB
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 格式 。
如何连接
在源连接器和接收器connector中使用以下配置选项指定连接 URI：
connection.uri=<your connection uri>
要了解有关此配置选项的更多信息，请参阅以下资源：
如何配置连接
MongoDB Kafka Connector 使用MongoDB Java 驱动程序来解析您的连接 URI。 MongoDB Java 驱动程序是一个工件，它使 Kafka Connect 等 Java 应用程序能够与 MongoDB 交互。
重要
驱动程序版本
版本1.14的MongoDB Kafka Connector使用版本4.7的MongoDB Java驾驶员。
要学习；了解连接器中可用的ConnectorURI 选项，请参阅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中身份验证的更多信息，请参阅安全和身份验证指南。