Docs Menu
Docs Home
/
MongoDB Kafka Connector
/
Sink Connector
/
構成プロパティ

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

項目一覧

  • Overview
  • 設定
  • 例

Overview

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

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

設定

名前
説明
topic.override.<topicName>.<propertyName>
Type: string

Description:
Specify a topic and property name to override the corresponding global or default property setting.

For example, the topic.override.foo.collection=bar setting instructs
the sink connector to store data from the foo topic in the bar
collection.

You can specify any valid configuration setting in the
<propertyName> segment on a per-topic basis except
connection.uri and topics.

Default: ""
Accepted Values: Accepted values specific to the overridden property

例

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

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

戻る

Sink Connector 書込みモデル戦略

次へ

データ キャプチャ プロパティの変更

項目一覧