源连接器的Kafka主题属性

topic.prefix

类型：字符串


描述：指定Connector变更流事件发布到的目标Kafka主题名称的第一部分。目标主题名称由topic.prefix 值组成，后跟数据库和集合名称，并用 属性中指定的值分隔。要学习；了解更多信息，请参阅主题命名前缀中的示例。默认值：topic.separator



""
接受的值：由 ASCII 字母数字字符组成的字符串，包括“.”、“-”和“_”

topic.suffix

类型：字符串


描述：指定Connector变更流事件发布到的目标Kafka主题名称的最后一部分。目标主题名称由数据库和集合名称组成，后跟topic.suffix 值，并用 属性中指定的值分隔。要学习；了解更多信息，请参阅主题命名后缀中的示例。默认值：topic.separator



""
接受的值：由 ASCII 字母数字字符组成的字符串，包括“.”、“-”和“_”

topic.namespace.map

类型：字符串


描述：指定变更流文档命名空间和主题名称之间的JSON映射。您可以使用

topic.namespace.map属性指定复杂的映射。此属性支持正则表达式和通配符匹配。要学习；了解有关这些行为的更多信息并查看示例，请参阅主题命名空间映射。默认值：



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

topic.separator

类型：字符串


描述：指定Connector用于连接用于创建主题名称的值的字符串。Connector将记录发布到主题，其名称是通过按以下顺序连接以下字段的值形成的：

1. topic.prefix

2. database

3. collection

4. topic.suffix

示例，以下配置指示Connector将变更流文档从 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 类实施的有效完整类名。