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

ストリーム プロパティの変更

MongoDB Kafka ソース コネクタを使用する場合、次の構成設定を使用して、変更ストリームの集計パイプラインと変更ストリーム カーソルの読み込み設定(read preference)を指定します。

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

名前
説明

パイプライン

Type: string

説明:
変更ストリームで実行する集計パイプラインの配列。この設定は、fullDocumentフィールドではなく、変更ストリームイベントドキュメントに対して構成する必要があります。

例:

[{"$match": { "$and": [{"operationType": "insert"}, {"fullDocument.eventId": 1404 }] } }]

その他の例については、次を参照してください:

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

change.stream. full.document

Type: string

Description:
Determines what values your change stream returns on update operations.

The default setting returns the differences between the original document and the updated document.

The updateLookup setting returns the differences between the original document and updated document as well as a copy of the entire updated document at a point in time after the update.

The whenAvailable setting returns the updated document, if available.

The required setting returns the updated document and raises an error if it is not available.

For more information on how this change stream option works, see Lookup Full Document for Update Operations in the MongoDB manual.

Default: ""
Accepted Values: "", "updateLookup", "whenAvailable", or "required"

change.stream.show.expanded.events

Type: boolean

Description:
Determines if change streams notifies for DDL events such as
createIndexes and
dropIndexes
events. To learn more, see showExpandedEvents.

This setting is required to show
updateDescription.disambiguatedPaths in update events, which
clarifies changes that involve ambiguous fields. To learn more,
see disambiguatedPaths.

Default: false
Accepted Values: true or false

change.stream. full.document.Before.change

Type: string

Description:
Configures the document pre-image your change stream returns on update operations. The pre-image is not available for source records published while copying existing data, and the pre-image configuration has no effect on copying.

To learn how to configure a collection to enable pre-images, see Change Streams with Document Pre- and Post-Images in the MongoDB manual.

The default setting suppresses the document pre-image.

The whenAvailable setting returns the document pre-image if it's available, before it was replaced, updated, or deleted.

The required setting returns the document pre-image and raises an error if it is not available.

Default: ""
Accepted Values: "" or "whenAvailable" or "required"

public. full.document.only

Type: boolean

Description:
Whether to return only the fullDocument field from the change stream event document produced by any update event. The fullDocument field contains the most current version of the updated document. To learn more about the fullDocument field, see the update Event in the Server manual.

When set to true, the connector overrides the change.stream.full.document setting and sets it to updateLookup so that the fullDocument field contains updated documents.

Default: false
Accepted Values: true or false

公開. full.document.only.tombzone.on.delete

タイプ: ブール値

説明:
ドキュメントが削除されたときにトンブストーン イベントを返すかどうか。トゥームストーンイベントには、null 値を持つ削除されたドキュメントのキーが含まれています。publish.full.document.onlytrueこの設定は、{1}が{2}の場合にのみ適用されます。

デフォルト: false
許容値: true または false

change.stream.document.key.as.key

型: ブール値

説明:
ドキュメント キーが存在する場合、ドキュメント キーをソース レコード キーとして使用するか否か。

true に設定すると、コネクターは削除されたドキュメントのキーをトンブストーン イベントに追加します。falseに設定すると、コネクターは再開トークンをトンブストーン イベントのソース キーとして使用します。

デフォルト: true
許容値: true または false

collation

Type: string

Description:
A JSON collation document that specifies language-specific ordering rules that MongoDB applies to the documents returned by the change stream.

Default: ""
Accepted Values: A valid collation JSON document

batch.size

型: int

説明:
変更ストリーム カーソルのバッチするサイズ。

デフォルト: 0
受け入れられる値: 整数

pay.await.time.ms

タイプ: long

説明:
空のバッチするを返す前に、新しいデータ変更が変更ストリーム カーソルに報告されるまでサーバーが待機する最大時間(ミリ秒)。

デフォルト: 5000
受け入れられる値: 整数

pay.max.batch.size

型: int

説明:
変更ストリームカーソルをポーリングして新しいデータを取得する際に、1 回のバッチするで読み取るドキュメントの最大数。この設定を使用することで、コネクタ内部でバッファリングされるデータ量を制限できます。

デフォルト: 1000
受け入れられる値: 整数

このページを評価

項目一覧