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

Overview

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

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

設定

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

名前

説明

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

タイプ: string

説明:
トピックとプロパティ名を指定して、対応するグローバルまたはデフォルトのプロパティ設定を上書きます。

例えば、設定は、シンクtopic.override.foo.collection=bar
コネクターに、トピックのデータをfoo bar
コレクションに保存するよう指示します。

<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を省略します。

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

戻る

モデル戦略の書込み

変更データのキャプチャ