4.4. MongoDB コネクターの仕組み
MongoDB コネクターが設定され、デプロイされると、シードアドレスの MongoDB サーバーに接続して開始し、利用可能な各レプリカセットの詳細を決定します。各レプリカセットには独自の独立した oplog があるため、コネクターはレプリカセットごとに個別のタスクを使用しようとします。コネクターは使用するタスクの最大数を制限できます。十分なタスクがない場合、コネクターは複数のレプリカセットを各タスクに割り当てますが、このタスクはレプリカセットごとに個別のスレッドを使用します。
注記
シャードクラスターに対してコネクターを実行する場合 tasks.max は、レプリカセット数よりも高い値を使用します。これにより、コネクターは各レプリカセットに対して 1 つのタスクを作成し、使用可能なすべてのワーカープロセスで Kafka Connect のコーディネート、配布、および管理が可能になります。
4.4.1. 論理コネクター名
コネクター設定プロパティーは、MongoDB レプリカセットまたはシャードクラスターの 論理名 として mongodb.name 機能します。コネクターは論理名を複数の方法で使用します。すべてのトピック名の接頭辞として、および各レプリカセットの oplog 位置の記録時には一意の識別子として使用されます。
各 MongoDB コネクターには、ソース MongoDB システムを説明する一意の論理名を指定する必要があります。論理名はアルファベット文字またはアンダースコアで始まり、英数字またはアンダースコア（小文字）の残りの文字で始まります。
