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

匹配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

相关产品推荐
方舟 Agent Plan

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

最近更新时间:2026.10.09 09:39:03