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

startup.mode

タイプ: string

説明:
ソース オフセットが利用できない場合にコネクターが起動する方法を指定します。変更ストリームを再開するにはレジュームトークンが必要で、コネクタはこのレジュームトークンをソースオフセットから取得します。ソース オフセットが利用できない場合、コネクタは既存のソース データのすべてまたは一部を無視することができます。または、最初にすべての既存のソース データをコピーして、その後、新しいデータのプロセシングを続行することができます。

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

startup.mode=timestamp の場合、コネクターは startup.mode.timestamp.* つのプロパティを作動させます。プロパティが設定されていない場合、timestamp は latest と同等です。

もし startup.mode=copy_existing の場合、コネクターは存在するすべてのソース データを Change Stream イベントにコピーします。この設定は、非推奨の設定 copy.existing=true と同等です。

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

デフォルト:latest
許容値:latest 、timestamp 、copy_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 データベース内の "page" で始まるコレクションに一致します。

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