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
相关产品推荐
相关产品推荐

