Flink cdc-connector databaselist 这个是不是不支持正则啊?

Flink cdc-connector databaselist 这个是不是不支持正则啊?image.png
但是我配置 好像不生效呢。。比如 我现在有一些库 aa_cc库 aa_bb库 我是不是应该设置 databaselist = aa.* 这样呢?

展开
收起
真的很搞笑 2023-11-01 14:20:13 107 分享 版权
2 条回答
写回答
取消 提交回答
  • Flink-CDC 数据库连接器通常支持正则表达式来匹配数据库名称,但具体的实现可能因版本和配置而异。您可以尝试使用正则表达式来匹配数据库名称,但需要确保您的配置正确。

    在配置 databaselist 时,您需要使用正确的正则表达式语法,并确保正则表达式与您的数据库名称匹配。根据您提供的信息,您可以尝试以下配置:

    databaselist = ^aa.*$
    

    上述配置使用了正则表达式 ^aa.*$,它匹配以 "aa" 开头且后面跟着任意字符的数据库名称。您可以将这个配置添加到您的 Flink-CDC 连接器配置中,然后重新启动 Flink 任务进行测试。

    2023-11-02 15:04:12
    赞同 展开评论
  • image.png
    ,此回答整理自钉群“Flink CDC 社区”

    2023-11-01 21:27:59
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理