主题覆盖属性

Overview

使用以下 MongoDB Kafka 接收器连接器配置设置来覆盖特定主题的全局或默认属性设置。

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

设置

名称	说明
topic.override.<topicName>.<propertyName>	类型：字符串描述：指定主题和属性名称以覆盖相应的全局或默认属性设置。示例， `topic.override.foo.collection=bar` 设置指示 SinkConnector将来自主题的数据存储在集合中。您可以在段中按主题指定任何有效的配置设置，但`foo` `bar` `<propertyName>` `connection.uri`和除外。默认值：`topics` `""` 接受值：特定于覆盖属性的接受值

名称

说明

topic.override.<topicName>.<propertyName>

类型：字符串描述：指定主题和属性名称以覆盖相应的全局或默认属性设置。示例，

topic.override.foo.collection=bar
设置指示 SinkConnector将来自主题的数据存储在集合中。您可以在段中按主题指定任何有效的配置设置，但foo bar

<propertyName>
connection.uri和除外。默认值：topics

""
接受值：特定于覆盖属性的接受值

例子

您可以覆盖接收器连接器以接收特定主题的数据。以下示例配置显示了如何为名为topicA的主题定义配置设置：

topic.override.topicA.collection=collectionA
topic.override.topicA.max.batch.size=100
topic.override.topicA.document.id.strategy=com.mongodb.kafka.connect.sink.processor.id.strategy.UuidStrategy
topic.override.topicA.post.processor.chain=com.mongodb.kafka.connect.sink.processor.DocumentIdAdder,com.mongodb.kafka.connect.sink.processor.BlockListValueProjector
topic.override.topicA.value.projection.type=BlockList
topic.override.topicA.value.projection.list=k2,k4

应用这些配置设置后，接收器connector会对topicA使用的数据执行以下操作：

将文档批量写入 MongoDB 集合collectionA ，最多 100 个。
为每个新文档生成一个 UUID 值并将其写入_id字段。
使用BlockList投影类型从值投影中省略字段k2和k4 。

有关如何配置阻止列表投影器的示例，请参阅帖子处理器指南。

后退

写入模型策略

来年

变更数据捕获