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
接続string URI 形式の詳細については、MongoDB マニュアルの「 接続 URI 形式 」を参照してください。
接続方法
ソース コネクタと Sink Connector の両方で、次の構成オプションで接続 URI を指定します。
connection.uri=<your connection uri>
この構成オプションの詳細については、次のリソースを参照してください。
接続の構成方法
MongoDB Kafka Connectorは、 MongoDB Javaドライバーを使用して接続 URI を解析します。 MongoDB Java ドライバーは、 Kafka Connect などの Java アプリケーションが MongoDB と交流できるようにするアーティファクトです。
重要
ドライバーのバージョン
MongoDB Kafka Connector のバージョン1.13は、MongoDB Java ドライバーのバージョン4.7を使用します。
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設定に認証シークレットがプレーン テキストとして保存されないようにするには、コネクターの起動時に安全な場所からシークレットをロードします。 コネクタの起動時にシークレットをロードする方法について は、Confluent の「 シークレットを外部化する 」ガイドを参照してください。
利用可能な認証メカニズムについては、「 MongoDB Java ドライバーの認証メカニズム 」のガイドを参照してください。
connector での認証の詳細については、「セキュリティと認証 」のガイドを参照してください。