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驱动程序。
要学习 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中身份验证的更多信息,请参阅安全和身份验证指南。