开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC现在有一些这样的库,里面的table都是一样的。 正则应该咋样写啊?

Flink CDC现在有一些这样的库,里面的table都是一样的。 我想监听这些库里的一个表的变更,我的配置是这样的。databaselist的正则应该咋样写啊?现在只监听到了其他的变更都没有收到消息 是我的database的正则写错了吗?image.png
image.png
image.png

展开
收起
真的很搞笑 2023-11-01 14:29:15 59 0
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    首先,Flink CDC支持在TiDB上使用,并且可以通过TiDB CDC连接器获取实时变化的数据。为了监听多个库中的相同表,你可以使用正则表达式来匹配你想要监听的所有库名。例如,如果你想要监听名为my_db_1、my_db_2、my_db_3等多个库中的my_table表,那么可以将database.whitelist设置为mydb\d+。
    另外,请确保你的Flink CDC配置正确,包括必要的连接参数和表模式信息。如果还有问题,请提供更多关于错误或警告的信息,

    2023-11-02 15:11:13
    赞同 1 展开评论 打赏
  • 根据您提供的图片,您的配置看起来是正确的。但是,为了确保正确监听到表的变更,请尝试以下步骤:

    1. 确保您的Flink CDC版本与您使用的库兼容。您可以查看库的文档以获取有关兼容性的信息。

    2. 检查您的数据库连接信息是否正确。确保您使用的是正确的用户名、密码和主机名。

    3. 检查您的正则表达式是否正确。在databaselist中,您需要提供一个正则表达式来匹配您想要监听的数据库名称。例如,如果您想要监听名为mydb的数据库,您可以使用以下正则表达式:

    ^mydb$
    
    1. 如果仍然无法收到消息,请查看Flink CDC的日志以获取更多详细信息。这可能会帮助您诊断问题并找到解决方案。
    2023-11-02 14:53:12
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载