/ /

/ /

MongoDB 命名空间映射配置属性

Overview

使用以下配置设置指定 MongoDB Kafka connector 将数据写入哪个 MongoDB database 和 collection。您可以使用默认的DefaultNamespaceMapper或指定自定义类。

有关按类别组织的接收器连接Connector配置设置列表，请参阅接收器连接器配置属性指南。

设置

名称

说明

namespace.mapper

类型：字符串

描述：指定将数据汇入哪个数据库或集合的类的完全限定类名。默认DefaultNamespaceMapper 使用和属性中指定的值。Connector包括一个用于指定数据库和集合的替代类，名为。有关更多信息，请参阅database collection

FieldPathNamespaceMapper
FieldPathNamespaceMapper 设置。默认值：

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

接受值：实现NamespaceMapper接口的类的完全限定 Java 类名称。

database

必需

类型：字符串

描述：接收器Connector写入的MongoDB 数据库的名称。接受值：

MongoDB 数据库名称

集合

类型：字符串

描述：SinkConnector写入的MongoDB集合的名称。如果 SinkConnector关注多个主题，则这是任何未另行指定的写入操作的默认集合。

默认：主题名称。

接受值：MongoDB collection名称

FieldPathNamespaceMapper 设置

如果将接收器连接器配置为使用FieldPathNamespaceMapper ，则可以根据数据的字段值指定用于接收文档的数据库和集合。

要启用此映射行为，请将接收器connectornamespace.mapper配置属性设置为完全限定的类名称，如下所示：

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

FieldPathNamespaceMapper要求您指定以下设置：

将属性映射到数据库和集合的一个或两个
到数据库的key或value映射之一
到collection的key或value映射之一

您可以使用以下设置自定义FieldPathNamespaceMapper的行为：

名称	说明
namespace.mapper.key.database.field	类型：字符串描述：关键文档字段的名称，用于指定要写入的数据库的名称。
namespace.mapper.key.collection.field	类型：字符串描述：关键文档字段的名称，用于指定要在其中写入的集合的名称。
namespace.mapper.value.database.field	类型：字符串描述：值文档字段的名称，该字段指定要写入的数据库的名称。
namespace.mapper.value.collection.field	类型：字符串描述：值文档字段的名称，该字段指定要在其中写入的集合的名称。
namespace.mapper.error.if.invalid	类型：布尔值描述：当文档缺少映射字段或其BSON类型无效时是否引发异常。设立为时，Connector不会进程缺少映射字段或包含无效BSON类型的文档。根据相关的错误处理配置设置，Connector可能会停止或跳过处理。设立为 `true` `false`时，如果文档缺少映射字段或其BSON类型无效，则Connector默认为写入指定的`database` 和`collection` 设置。默认值： `false` 接受值：`true` 或`false`

后退

MongoDB 连接

来年

Kafka主题