源连接器的Kafka主题属性

topic.prefix

类型：string

说明：
指定连接器将变更流事件发布到的目标 Kafka 主题名称的第一部分。目标主题名称的组成：topic.prefix 值，后跟数据库和集合名称，由 topic.separator 属性中指定的值分隔。

要了解更多信息，请参阅主题命名规则中的示例。

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

topic.suffix

类型：string

说明：
指定连接器将变更流事件发布到的目标 Kafka 主题名称的最后一部分。目标主题名称由数据库和集合名称后跟 topic.suffix 值组成，并由 topic.separator 属性中指定的值分隔。

要了解更多信息，请参阅主题命名后缀中的示例。

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

topic.namespace.map

Type: string

Description:
Specifies a JSON mapping between change stream document namespaces and topic names.

You can use to topic.namespace.map property to specify complex mappings. This property supports regex and wildcard matching.

To learn more about these behaviors and view examples, see Topic Namespace Map.

Default: ""
Accepted Values: A valid JSON object

topic.separator

类型：string

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

1. topic.prefix

2. database

3. collection

4. topic.suffix

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

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

IMPORTANT: When you use the topic.separator property, note that it doesn't affect how you define the topic.namespace.map property. The topic.namespace.map property uses MongoDB namespaces which you must always specify with a . character to separate the database and collection name.

Default: "."
Accepted Values: A string

topic.mapper

类型：string

说明：
定义自定义主题映射逻辑的 Java 类。

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