トピック上書きプロパティ

Overview

次の MongoDB Kafka Sink Connector 構成設定を使用して、特定のトピックのグローバルまたはデフォルトのプロパティ設定をオーバーライドします。

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

設定

名前	説明
topic.<topicName> overwrite.{tolicName>.<propertyName>	タイプ: string 説明:トピック名とプロパティ名を指定して、対応するグローバルまたはデフォルトのプロパティ設定を上書きします。例、`topic.override.foo.collection=bar` 設定は、トピックのデータを`foo` `bar` コレクションに保存するように Sink コネクタに指示します。セグメントでは、 `<propertyName>` `connection.uri`とを除き、トピックごとに任意の有効な構成設定を指定できます。デフォルト:`topics` `""` 許容値: オーバーライドプロパティに固有の許容値

名前

説明

topic.<topicName> overwrite.{tolicName>.<propertyName>

タイプ: string

説明:トピック名とプロパティ名を指定して、対応するグローバルまたはデフォルトのプロパティ設定を上書きします。例、topic.override.foo.collection=bar 設定は、
トピックのデータをfoo bar
コレクションに保存するように Sink コネクタに指示します。セグメントでは、

<propertyName>
connection.uriとを除き、トピックごとに任意の有効な構成設定を指定できます。デフォルト:topics

""
許容値: オーバーライドプロパティに固有の許容値

例

Sink Connector をオーバーライドして、特定のトピックからのデータをシンクできます。次の構成例は、 topicAという名前のトピックの構成設定を定義する方法を示しています。

topic.override.topicA.collection=collectionA
topic.override.topicA.max.batch.size=100
topic.override.topicA.document.id.strategy=com.mongodb.kafka.connect.sink.processor.id.strategy.UuidStrategy
topic.override.topicA.post.processor.chain=com.mongodb.kafka.connect.sink.processor.DocumentIdAdder,com.mongodb.kafka.connect.sink.processor.BlockListValueProjector
topic.override.topicA.value.projection.type=BlockList
topic.override.topicA.value.projection.list=k2,k4

これらの構成設定を適用すると、Sink Connector はtopicAから消費されるデータに対して次の処理を実行します。

MongoDB コレクションcollectionAにドキュメントを最大 100 のバッチで書き込みます。
新しいドキュメントごとに UUID 値を生成し、それを_idフィールドに書き込みます。
BlockListプロジェクションタイプを使用して、値プロジェクションからフィールドk2とk4を省略します。

ブロックリストプロジェクションの構成方法の例については、ポストプロセッサのガイドを参照してください。

戻る

モデル戦略の書込み

変更データのキャプチャ