/ /

MongoDB 名前空間マッピング構成プロパティ

Overview

次の構成設定を使用して、MongoDB Kafka Sink Connector がデータを書き込む MongoDB database とコレクションを指定します。デフォルトのDefaultNamespaceMapperを使用することも、カスタムクラスを指定することもできます。

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

設定

名前

説明

namespace.mapper

タイプ: string

説明:
データをシンクするデータベースまたはコレクションを指定するクラスの完全修飾クラス名。デフォルトの DefaultNamespaceMapper では、database プロパティと collection プロパティで指定された値が使用されます。

FieldPathNamespaceMapperコネクタには、と呼ばれるデータベースとコレクションを指定するための代替クラスが含まれています。詳細については、
FieldPathNamespaceMapper 設定
を参照してください。

デフォルト:

com.mongodb.kafka.connect.sink.namespace.mapping.DefaultNamespaceMapper

受け入れ値: NamespaceMapperインターフェースを実装するクラスの完全修飾 Java クラス名。

database

必須

タイプ: string

説明:
シンクコネクターが書き込む MongoDB データベースの名前。

受け入れられる値: MongoDB データベース名

コレクション

タイプ: string

説明:
シンクコネクターの書き込み (write) 先となる MongoDB コレクションの名前。シンクコネクターが複数のトピックをフォローする場合、これはその他に指定されていない書き込みのデフォルトコレクションです。

デフォルト: トピック名。

許容値: MongoDB コレクション名

FieldPathNamespaceMapper の設定

FieldPathNamespaceMapperを使用するように Sink Connector を構成すると、データのフィールド値に基づいて、ドキュメントを Sink するデータベースとコレクションを指定できます。

このマッピング動作を有効にするには、以下に示すように、Sink Connector namespace.mapper構成プロパティを完全修飾クラス名に設定します。

namespace.mapper=com.mongodb.kafka.connect.sink.namespace.mapping.FieldPathNamespaceMapper

FieldPathNamespaceMapperでは、次の設定を指定する必要があります。

プロパティをデータベースとコレクションにマッピングする 1 つまたは両方
データベースへのkeyまたはvalueマッピングの 1 つ
コレクションへのマッピングまたはマッピングの 1 つkeyvalue

FieldPathNamespaceMapperの動作をカスタマイズするには、次の設定を使用します。

名前	説明
namespace.mapper.key.database.field	タイプ: string 説明: 書き込み先のデータベース名を指定するキードキュメントフィールドの名前。
namespace.mapper.key.collection.field	型: string 説明: 書き込むコレクションの名前を指定するキードキュメントフィールドの名前。
namespace.mapper.value.database.field	タイプ: string 説明: 書き込み先のデータベース名を指定する値ドキュメントフィールドの名前。
namespace.mapper.value.collection.field	タイプ: string 説明: 書き込むコレクションの名前を指定する値ドキュメントフィールドの名前。
namespace.mapper.error.if.invalid	タイプ: ブール値説明: ドキュメントにマップされたフィールドがない場合、または無効な BSON タイプがある場合に例外をスローするかどうか。 `true` に設定すると、マップされたフィールドがないドキュメント、または無効な BSON タイプを含むドキュメントはコネクターによってプロセシングされません。コネクターは関連するエラー処理の構成設定に応じて、プロセシングを停止またはスキップする場合があります。 `false` に設定すると、ドキュメントにマップされたフィールドがない場合、または無効な BSON タイプがある場合、コネクターは指定された `database` および `collection` 設定への書き込みをデフォルトとします。デフォルト: `false` 受け入れられる値: `true` または `false`

戻る

MongoDB 接続

Kafkaトピック