Docs 菜单
Docs 主页
/
MongoDB Kafka Connector
/
接收器连接器
/
配置属性

主题覆盖属性

在此页面上

  • Overview
  • 设置
  • 例子

Overview

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

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

设置

名称
说明
topic.override.<topicName>.<propertyName>
Type: string

Description:
Specify a topic and property name to override the corresponding global or default property setting.

For example, the topic.override.foo.collection=bar setting instructs
the sink connector to store data from the foo topic in the bar
collection.

You can specify any valid configuration setting in the
<propertyName> segment on a per-topic basis except
connection.uri and topics.

Default: ""
Accepted Values: Accepted values specific to the overridden property

例子

您可以覆盖接收器连接器以接收特定主题的数据。 以下示例配置显示了如何为名为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 。

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

后退

接收连接器写入模型策略

来年

更改数据捕获属性

在此页面上