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

在使用cdc采集的时候。连接mysql库一个表会生成一个连接。批量采集的话这个连接数有方式降下来吗?

在使用cdc采集的时候。连接mysql库发现一个表会生成一个连接。对批量采集的话,对mysql库的连接数过多。这个连接数有方式降下来吗。flink-sql-connector-mysql-cdc-2.2.1.jar这是使用的连接jar包版本。

展开
收起
wenti 2023-02-06 15:25:32 161 0
2 条回答
写回答
取消 提交回答
  • 合并监控任务:如果可能的话,尝试将对多个表的监控逻辑合并为单个 CDC 监控任务,这样它们可以共享一个数据库连接。但这通常需要表之间有相似的数据和更新模式。

    使用连接池:尽管每个CDC实例可能需要一个独立的逻辑连接,但可以配置连接池技术来减少物理连接的数量。连接池能够在内部重用和管理数据库连接。

    优化业务逻辑:取决于你的实时业务需求,可能可以将部分表或实时处理逻辑延迟执行或按批次处理,从而减少同时进行的连接数。

    调整数据库配置:增加数据库服务器允许的最大连接数,以适应更多并发连接。

    使用 Flink SQL CDC:在 Flink SQL API 中可以通过一条 SQL 语句监控多个表,可能会有助于降低对同时连接数量的需求。

    数据库中间件/代理:使用数据库中间件或代理服务,使得 Flink CDC 通过代理连接到数据库,由代理来管理和优化数据库连接,降低对数据库本身连接数的要求。

    资源扩展:如果确实需要监控大量表,并且不能降低连接数,可能需要考虑通过增加数据库服务器资源或者对数据库进行水平扩展来处理这种高并发情况。

    升级 Flink 版本:随着 Flink CDC 连接器的不断发展,未来可能会提供更优的连接管理策略,更新 Flink 版本到最新版可能有助于解决问题。

    2024-02-26 17:53:19
    赞同 展开评论 打赏
  • 你写了多次,那不就是多个,多表或者整库同步不建议用sql——该回答整理自钉群“Flink CDC 社区”

    2023-02-06 19:20:02
    赞同 展开评论 打赏

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

热门讨论

热门文章

相关电子书

更多
One Box: 解读事务与分析一体化数据库 HybridDB for MySQL 立即下载
One Box:解读事务与分析一体化数据库HybridDB for MySQL 立即下载
如何支撑HTAP场景-HybridDB for MySQL系统架构和技术演进 立即下载

相关镜像