Overview
次の構成設定を使用して、MongoDB Kafka ソース コネクタの起動を構成し、MongoDB コレクションを Change Stream イベントに変換します。
Tip
既存のコピー機能を使用する例については、「既存のデータをコピーする使用例 」を参照してください。
カテゴリ別に整理されたソース コネクタ構成設定のリストについては、「ソースConnector構成プロパティ 」に関するガイドを参照してください。
設定
名前 | 説明 | |
|---|---|---|
startup.mode | タイプ: string ソース コネクタが既存のデータを変換するときに、いずれかのシステムがデータベース内のデータを変更した場合、MongoDB は最新の変更を反映するために重複した変更ストリーム イベントを生成することがあります。 データコピーが依存する変更ストリーム イベントは偶数であるため、コピーされたデータは結果整合性があります。 Default: | |
startup.mode.timestamp.start.at.operation.time | タイプ: string
| |
startup.mode. copy.existing.namespace.regex | タイプ: string The | |
startup.mode. copy.existing. pipeline | タイプ: string デフォルト: | |
startup.mode. copy.existing.max.threads | タイプ: int | |
startup.mode. copy.existing.queue.size | タイプ: int | |
startup.mode. copy.existing.allow.disk.use | タイプ:ブール値値 |