AI エージェント向け: ドキュメントインデックスは https://www.mongodb.com/ja-jp/docs/llms.txt で利用できます。すべてのページの markdown バージョンは、いずれかの URL パスに .md を追加することで利用できます。
Make the MongoDB docs better! We value your opinion. Share your feedback for a chance to win $100.
MongoDB Branding Shape
Click here >
Docs Menu

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

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

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

名前
説明

パイプライン

タイプ: string


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

(例: )。

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

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

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

change.stream. full.document

タイプ: string






説明:updateLookup アップデート操作時に変更ストリームが返す値を決定します。デフォルト設定では、元のドキュメントと更新されたドキュメントとの差が返されます。

whenAvailable設定は、元のドキュメントと更新されたドキュメントとの差、および更新後の特定の点での更新されたドキュメント全体のコピーを返します。

required設定は更新されたドキュメントを返します(利用可能な場合)。

設定は更新されたドキュメントを返し、ドキュメントが利用できない場合はエラーを発生させます。この変更ストリームオプションの機能の詳細については、 MongoDBマニュアルの「 更新操作のための完全なドキュメントの検索

」を参照してください。デフォルト:""
許容値:"""updateLookup""whenAvailable" 、または"required"

change.stream.show.expanded.events

タイプ:ブール値値

説明:
変更ストリームが
createIndexes イベントや
dropIndexes
イベントなどの DDL イベントを通知するかどうかを決定します。詳しくは、 showExpandedEvents を参照してください。この設定は、アップデート


updateDescription.disambiguatedPathsイベントで
を表示するために必要です。これにより、あいまいなフィールドを含む変更が明確になります。詳しくは、
disabledPaths を参照してください。デフォルト:

false
許容値:true またはfalse

change.stream. full.document.Before.change

タイプ: string

説明:
アップデート操作時に変更ストリームが返す変更前のドキュメントを構成します。変更前のイメージは、既存のデータのコピー中に公開されたソース レコードでは使用できず、変更前のイメージ構成はコピーに影響しません。変更前イメージを有効にするようにコレクションを構成する方法については、

MongoDBマニュアルの「 Change Streams とドキュメントの変更前イメージおよび変更後イメージ

」を参照してください。デフォルト設定では、ドキュメントの変更前のイメージは非表示にされます。

whenAvailable設定では、置換、アップデート、または削除される前に、ドキュメントが利用可能な場合、変更前のイメージが返されます。

required設定では、ドキュメントの変更前のイメージが返され、利用できない場合はエラーが発生します。デフォルト:

""
許容値:"" または"whenAvailable" または"required"

public. full.document.only

タイプ:ブール値値

説明:
fullDocumentfullDocumentfullDocument更新イベントによって生成された変更ストリームイベントドキュメントから フィールドのみを返すかどうか。 フィールドには更新されたドキュメントの最新バージョンが含まれます。 フィールドの詳細については、サーバー マニュアルの更新イベントを参照してください。

trueに設定すると、コネクタは 設定を上書きし、それを に設定して、 フィールドに更新されたドキュメントが含まれるようにします。デフォルト:change.stream.full.document updateLookupfullDocument

false
許容値:true またはfalse

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

タイプ:ブール値値

説明:
ドキュメントが削除されたときにトゥームストーンnull イベントを返すかどうか。 Toms の イベントには、 値を持つ削除されたドキュメントのキーが含まれます。この設定は、publish.full.document.only が の場合にのみ適用されます。デフォルト:true

false
許容値:true またはfalse

change.stream.document.key.as.key

タイプ:ブール値値


説明:ドキュメントキーが存在する場合、ソースレコードキーにドキュメントキーを使用するかどうか。

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

true
許容値:true またはfalse

collation

タイプ: string


説明:変更ストリームによって返されるドキュメントにMongoDB が適用する言語固有の順序付けルールを指定するJSON照合ドキュメント。デフォルト:

""
許容値: 有効な照合JSONドキュメント

batch.size

タイプ: int


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

0
許容値: 整数

pay.await.time.ms

タイプ: long

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

5000
許容値: 整数

pay.max.batch.size

タイプ: int 説明:変更ストリームカーソルをポーリングして新しいデータを検索するときに、1


つのバッチするで読み込むドキュメントの最大数。この設定を使用すると、コネクタの内部でバッファされるデータの量を制限できます。デフォルト:

1000
許容値: 整数

項目一覧