AI エージェント向け: ドキュメントインデックスは https://www.mongodb.com/ja-jp/docs/llms.txt で利用できます。すべてのページの markdown バージョンは、いずれかの URL パスに .md を追加することで利用できます。
Docs Menu

スタートアップ プロパティ

次の構成設定を使用して、MongoDB Kafka ソース コネクタの起動を構成し、MongoDB コレクションを Change Stream イベントに変換します。

Tip

既存のコピー機能を使用する例については、「既存のデータをコピーする使用例 」を参照してください。

カテゴリ別に整理されたソース コネクタ構成設定のリストについては、「ソースConnector構成プロパティ 」に関するガイドを参照してください。

名前
説明

startup.mode

タイプ: string

説明:
使用可能なソース オフセットがない場合にコネクタを起動する方法を指定します。変更ストリームを再開するには、コネクタがソース オフセットから取得する再開トークンが必要です。ソース オフセットが使用できない場合、コネクタは既存のソース データのすべてまたは一部を無視するか、最初に既存のソース データをコピーして新しいデータの処理を続行する可能性があります。

startup.mode=latestの場合、コネクタは既存のソース データをすべて無視します。

startup.mode=timestampの場合、コネクタはstartup.mode.timestamp.* プロパティを有効化します。プロパティが構成されていない場合、timestamplatest と同等です。

startup.mode=copy_existingの場合、コネクタは既存のすべてのソースデータを 変更ストリーム イベントにコピーします。この設定は、非推奨の設定copy.existing=true と同じです。

ソースコネクタが既存のデータを変換するときに、いずれかのシステムがデータベース内のデータを変更した場合、 MongoDB は最新の変更を反映するために重複した変更ストリームイベントを生成することがあります。データコピーが依存する変更ストリームイベントが冪等であるため、コピーされたデータは結果整合性があり、"少なくとも 1 回" の配信保証に準拠します。

デフォルト:latest
許容値:latesttimestampcopy_existing

startup.mode.timestamp.start.at.operation.time

タイプ: string

説明:
startup.mode=timestampの場合にのみ有効になります。変更ストリームの開始点を指定します。

Change Stream パラメーターの詳細については、 MongoDBマニュアルの $changeStream(集計)を参照してください。デフォルト:

""
許容値:

  • 10進数形式での UNIXエポックからの整数(例: 30

  • 1 秒の精度を持つ ISO-8601 形式のインスタンス(例: 1970-01-01T00:00:30Z

  • 標準拡張 JSON(v2)形式の BSON タイムスタンプ(例: {"$timestamp": {"t": 30, "i": 0}}

startup.mode. copy.existing.namespace.regex

タイプ: string


説明:コネクタが、データのコピー元となる名前空間を一致させるために使用する正規式。名前空間は、MongoDBデータベース名とコレクションをピリオドで区切って記述します(例: 、databaseName.collectionName

)。例、次の正規表現設定は、stats データベース内の「ページ」で始まるコレクションと一致します。

startup.mode.copy.existing.namespace.regex=stats\.page.*

\上記の例では、. 文字は、正規式内のそれに続く 文字をエスケープします。正規表現の構築方法の詳細については、 Java APIドキュメントの パターン

を参照してください。デフォルト:""
許容値: 有効な正規式

startup.mode. copy.existing. pipeline

タイプ: string

説明:
既存のデータをコピーするときにコネクタが実行するパイプライン操作のインライン配列。この設定を使用すると、ソースコレクションをフィルタリングし、コピー

プロセスにおけるインデックスの使用を改善できます。例、次の設定では $match集計子を使用して、 closedの値を持つfalse フィールドを含むドキュメントのみをコピーするようにコネクタに指示します。

startup.mode.copy.existing.pipeline=[ { "$match": { "closed": "false" } } ]

デフォルト:""
許容値: 有効な集計パイプラインステージ

startup.mode. copy.existing.max.threads

タイプ: int

説明:コネクタがデータをコピーするために使用できるスレッドの最大数。デフォルト:


環境で使用可能なプロセッサの数
許容値: 整数

startup.mode. copy.existing.queue.size

タイプ: int

説明:
データをコピーするときにコネクタ が使用できるキューのサイズ。デフォルト:

16000
許容値: 整数

startup.mode. copy.existing.allow.disk.use

タイプ:ブール値値

説明:
trueに設定すると、コネクタは既存の集計に一時ディスクストレージを使用します。デフォルト:

true
許容値:true またはfalse

項目一覧