MongoDB 命名空间映射配置属性

Overview

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

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

设置

名称

说明

namespace.mapper

Type: string

Description:
The fully-qualified class name of the class that specifies which database or collection in which to sink the data. The default DefaultNamespaceMapper uses values specified in the database and collection properties.

The connector includes an alternative class for specifying the
database and collection called FieldPathNamespaceMapper. See
FieldPathNamespaceMapper Settings
for more information.

Default:

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

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

database

必需

类型：string

说明：
汇入连接器写入的 MongoDB 数据库名称。

已接受值：MongoDB 数据库名称

集合

类型：string

说明：
汇入连接器写入的 MongoDB 集合的名称。如果汇入连接器跟随多个主题，则这是未另外指定的任何写入的默认集合。

默认：主题名称。

接受值：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	类型：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`