MongoDB 命名空间映射配置属性
概述
使用以下配置设置来指定您的 MongoDB Kafka 接收连接器写入数据的 MongoDB 数据库和集合。您可以使用默认DefaultNamespaceMapper 或指定一个自定义类。
有关按类别组织的连接器配置设置列表，请参阅关于连接器配置属性
的指南 .设置
名称 | 描述 | |
|---|---|---|
namespace.mapper | 类型: 字符串 描述: 指定要将其数据输出到的数据库或集合的类的完全限定类名。默认的 DefaultNamespaceMapper 使用在 database 和 collection 属性中指定的值。连接器包含一个用于指定数据库和集合的备用类，称为 FieldPathNamespaceMapper。有关更多信息，请参见默认 可接受值：实现 NamespaceMapper 接口的类的完全限定 Java 类名。:database | |
必需 | 连接器写入的 MongoDB 数据库名称。 类型: 字符串 描述: 可接受值：MongoDB 数据库名称 collection | |
连接器写入的 MongoDB 集合名称。如果您的连接器遵循多个主题，则这是任何未指定其他写入的默认集合。 |
如果您配置您的连接器以使用 FieldPathNamespaceMapper，则可以指定根据数据字段的值将文档输出到哪个数据库和集合。
要启用此映射行为，请将您的连接器 namespace.mapper 配置属性设置为如下所示的完全限定类名
namespace.mapper=com.mongodb.kafka.connect.sink.namespace.mapping.FieldPathNamespaceMapper
FieldPathNamespaceMapper 需要您指定以下设置
将一个或多个映射属性映射到数据库和集合
将一个或多个
key或value映射到数据库将一个或多个
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 | 类型: boolean 描述: 当文档缺少映射字段或具有无效的 BSON 类型时，是否抛出异常。 当设置为 true 时，连接器不会处理缺少映射字段或包含无效 BSON 类型的文档。连接器的停止或跳过处理取决于相关的错误处理配置设置。当设置为 false 时，如果文档缺少映射字段或具有无效的 BSON 类型，连接器默认写入指定的 database 和 collection 设置。默认值: false可接受值: true 或 false |