既存のプロパティをコピーする

項目一覧

Overview

設定

Overview

重要

**copy.existing* プロパティは非推奨**

MongoDB Kafka Connector のバージョン1.9以降、 copy.existing*プロパティは非推奨であり、将来のリリースで削除される可能性があります。既存のコピー機能を構成するには、 startup.mode*プロパティを使用する必要があります。 startup.mode*設定の詳細については、起動プロパティを参照してください。

次の構成設定を使用して、MongoDB コレクションを変更ストリームイベントに変換する既存のコピー機能を有効にします。

Tip

以下も参照してください。

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

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

設定

名前

説明

copy.existing

Type: boolean

Description:
Whether to enable the copy existing feature which converts all
data in a MongoDB collection to Change Stream events and
publishes them on Kafka topics. If MongoDB changes the source
collection data after the connector starts the copy process, the
connector creates events for the changes after it completes the copy
process.

ソースコネクタが既存のデータを変換するときに、いずれかのシステムがデータベース内のデータを変更した場合、MongoDB は最新の変更を反映するために重複した変更ストリームイベントを生成することがあります。データコピーが依存する変更ストリームイベントは偶数であるため、コピーされたデータは結果整合性があります。

Default:false

Accepted Values: true or false

copy.existing.namespace.regex

Type: string

Description:
Regular expression the connector uses to match namespaces from
which to copy data. A namespace describes the MongoDB database name
and collection separated by a period (for example, databaseName.collectionName).

例

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

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

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

Default: ""

Accepted Values: A valid regular expression

copy.existing.pipeline

Type: string

Description:
An array of pipeline operations
the connector runs when copying existing data. You can use this
setting to filter the source collection and improve the use of
indexes in the copying process.

例

次の例は、 $match集計演算子を使用して、値がfalseであるclosedフィールドを含むドキュメントのみをコピーするようにコネクタに指示する方法を示しています。

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

Default: []

Accepted Values: Valid aggregation pipeline stages

copy.existing.max.threads

Type: int

Description:
The maximum number of threads the connector can use to copy data.
Default: number of processors available in the environment
Accepted Values: An integer

copy.existing.queue.size

Type: int

Description:
The size of the queue the connector can use when copying data.
Default: 16000
Accepted Values: An integer

copy.existing.allow.disk.use

Type: boolean

Description:
When set to true, the connector uses temporary disk storage
for the copy existing aggregation.
Default: true

MongoDB Kafka Connector