Kafka Mongosink连接器排除主题

idfiyjo8  于 2023-03-17  发布在  Apache
关注(0)|答案(1)|浏览(83)

我有一个用于Kafka集群的mongo接收器连接器,它将主题数据接收到mongo数据库中。我正在寻找一些属性来排除接收器连接器中的一个主题。
说明:
1.本地测试数据
1.本地测试数据状态
1.本地测试数据克隆
这3个是我在Kafka的主题和我的sink主题。regex是local. test。* 但是我不想sink local.test.data-status,我需要排除这个特定的主题。
是否有可用于执行此操作的属性

ymdaylpp

ymdaylpp1#

更改正则表达式以仅捕获所需的主题

local.test.data(Clone)?

或者使用带有CSV列表的topics,而不是topic.regex

相关问题