我有一个用于Kafka集群的mongo接收器连接器,它将主题数据接收到mongo数据库中。我正在寻找一些属性来排除接收器连接器中的一个主题。
说明:
1.本地测试数据
1.本地测试数据状态
1.本地测试数据克隆
这3个是我在Kafka的主题和我的sink主题。regex是local. test。* 但是我不想sink local.test.data-status,我需要排除这个特定的主题。
是否有可用于执行此操作的属性
我有一个用于Kafka集群的mongo接收器连接器,它将主题数据接收到mongo数据库中。我正在寻找一些属性来排除接收器连接器中的一个主题。
说明:
1.本地测试数据
1.本地测试数据状态
1.本地测试数据克隆
这3个是我在Kafka的主题和我的sink主题。regex是local. test。* 但是我不想sink local.test.data-status,我需要排除这个特定的主题。
是否有可用于执行此操作的属性
1条答案
按热度按时间ymdaylpp1#
更改正则表达式以仅捕获所需的主题
或者使用带有CSV列表的
topics
,而不是topic.regex