Docs 菜单

Docs 主页 → 开发应用程序 → MongoDB Kafka Connector

主题覆盖属性

在此页面上

  • 概述
  • 设置
  • 例子

概述

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

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

设置

名称
说明
topic.override.<topicName>.<propertyName>
类型：字符串

描述：
指定主题和属性名称以覆盖相应的全局或默认属性设置。

例子

topic.override.foo.collection=bar设置指示接收器连接器将来自foo主题的数据存储在bar集合中。

注意

您可以在<propertyName>段中按主题指定任何有效的配置设置，但connection.uri和topics除外。

默认：""。
Accepted Values ：特定于被重写属性的接受值

例子

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

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

← 接收连接器写入模型策略
更改数据捕获属性 →

在此页面上