Kafka 主题属性

本页内容

概述

设置

概述

使用以下配置设置指定MongoDB Kafka源连接器应将数据发布到哪些Kafka主题。

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

设置

名称

描述

topic.prefix

类型：字符串

描述
指定连接器发布更改流事件的目标Kafka主题名称的前一部分。目标主题名称由topic.prefix值后面跟数据库和集合名称组成，名称之间由topic.separator属性指定的值分隔。

有关更多信息，请参阅主题命名前缀示例。

默认值：""
可接受值：由ASCII字母数字字符组成，包括"."、"-"和"_"

topic.suffix

类型：字符串

描述
指定连接器发布更改流事件的目标Kafka主题名称的后一部分。目标主题名称由数据库和集合名称后面跟topic.suffix值组成，名称之间由topic.separator属性指定的值分隔。

有关更多信息，请参阅主题命名后缀示例。

默认值：""
可接受值：由ASCII字母数字字符组成，包括"."、"-"和"_"

topic.namespace.map

类型：字符串

描述
指定更改流文档命名空间和主题名称之间的JSON映射。

您可以使用topic.namespace.map属性指定复杂的映射。此属性支持正则表达式和通配符匹配。

要了解更多关于这些行为和查看示例，请参阅主题命名空间映射。

默认值：""
接受值：有效的JSON对象

topic.separator

类型：字符串

描述
指定连接器用于连接创建主题名称的值的字符串。连接器将记录发布到以以下顺序连接以下字段值的主题：

topic.prefix
database
collection
topic.suffix

例如，以下配置指示连接器将来自数据库db的集合coll的变化流文档发布到prefix-db-coll主题。

topic.prefix=prefix
database=db
collection=coll
topic.separator=-

重要：当您使用topic.separator属性时，请注意它不会影响您定义topic.namespace.map属性的方式。该topic.namespace.map属性使用MongoDB 命名空间，您必须始终使用点.字符来分隔数据库和集合名称。

默认值："."
接受值：字符串

topic.mapper

类型：字符串

描述
定义您的自定义主题映射逻辑的Java类。

默认值：com.mongodb.kafka.connect.source.topic.mapping.DefaultTopicMapper
接受值：实现TopicMapper类的有效完整类名。

MongoDB 连接

下一步

更改流