You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Kafka Mongo Sink Connector如何排除指定主题不进行数据同步?

Kafka Mongo Sink Connector 排除指定主题的配置方法

Mongo Sink Connector本身没有单独的"排除主题"配置属性,但可以通过两种方式实现你的需求:

调整正则表达式(推荐)

直接修改topic.regex的正则规则,利用负向预查排除目标主题:

topic.regex=local.test.(?!data-status).*

这个正则的逻辑是:匹配以local.test.开头,且后续内容不是data-status的所有主题,刚好能命中你需要同步的local.test.data和local.test.dataClone,同时跳过local.test.data-status。

直接指定需同步的主题

如果涉及的主题数量不多,也可以放弃topic.regex,改用topics配置项直接列出要同步的主题:

topics=local.test.data,local.test.dataClone

这种方式更直观,后续维护起来也更清晰。

内容的提问来源于stack exchange,提问作者Abhishek

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.07.28 20:12:05