匹配mysql-db01.*且排除指定主题的Kafka Connect正则如何写?
Kafka Connect 主题匹配正则解决方案
你需要的正则规则如下:mysql-db01\.(?!schema-changes\.mysql$).*
规则说明
mysql-db01\.:严格匹配前缀mysql-db01.,此处的点号使用反斜杠转义,避免被正则识别为任意字符通配符(?!schema-changes\.mysql$):负向先行断言,标识当前位置之后不能正好是schema-changes.mysql结尾,$符号保证完全匹配,不会误伤其他前缀类似的合法主题.*:匹配前缀之后的任意内容,覆盖所有符合mysql-db01.*格式的其余主题
匹配效果验证
Kafka Connect 的
topics.regex配置默认对完整主题名做匹配,以上正则可以实现以下效果:
- 可匹配的主题示例:
mysql-db01.user、mysql-db01.order.detail、mysql-db01.schema-changes.postgres - 被排除的主题:仅
mysql-db01.schema-changes.mysql
内容的提问来源于stack exchange,提问作者TheDataGuy
相关产品推荐
相关产品推荐

