/ /

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

説明:
Sink コネクタが書込むMongoDBデータベースの名前。受け入れ値:

MongoDBデータベース名

コレクション

タイプ: string

説明:
Sink コネクタが書込むMongoDBコレクションの名前。 Sink コネクタが複数のトピックに従う場合、これは特に指定されていない書込みのデフォルトのコレクションです。

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

許容値: 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 説明: 書込み (write) するデータベースの名前を指定するキードキュメントフィールドの名前。
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トピック