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

官网描述是目前2.3.0 cdc支持的pg版本包含PostgreSQL: 9.6, 10, 11,?

官网描述是目前2.3.0 cdc支持的pg版本包含PostgreSQL: 9.6, 10, 11, 12,是因为对pg 13版本不支持所以报错上面的问题吗,或者是因为我的配置有些问题 环境 1、Flink version : 1.16.1 2、Flink CDC version: 2.3.0 3、Database and version: PostgreSQL 13.5

cdc采集报错:Could not initialize class io.debezium.embedded.EmbeddedEngine$EmbeddedConfig 我在issue看到了类似的问题,已经close了,并没有详细的回复,https://github.com/ververica/flink-cdc-connectors/issues/1819有没有大佬试验过2.3.0 cdc采集PostgreSQL 13.5?

展开
收起
真的很搞笑 2023-07-02 17:54:24 156 0
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    根据 Flink 官网的描述,Flink CDC 在 2.3.0 版本中支持的 PostgreSQL 版本包括 9.6、10、11 和 12。如果您使用的是 PostgreSQL 13,可能会导致 CDC 无法正常工作或者报错。
    具体来说,如果您在使用 Flink CDC 连接 PostgreSQL 13 数据库时遇到了问题,可能是因为 CDC 与 PostgreSQL 13 不兼容,或者是因为您的配置有误。建议您检查以下几个方面:
    确认 Flink CDC 的版本和配置是否正确:请确保您使用的是 Flink CDC 2.3.0 版本,并且已经正确配置了 PostgreSQL 数据库的连接信息和参数。
    检查 PostgreSQL 数据库的版本:请检查您使用的 PostgreSQL 数据库的版本是否为 13,并且是否与 Flink CDC 兼容。如果您使用的是 PostgreSQL 13,建议您升级到支持的版本(例如 12),或者等待 Flink CDC 更新以支持 PostgreSQL 13。
    检查连接和权限:请检查 Flink CDC 连接 PostgreSQL 数据库的用户是否具有足够的权限,并且网络连接是否正常。

    2023-07-30 09:36:44
    赞同 展开评论 打赏
  • 根据官方文档,Flink CDC 2.3.0 支持的 PostgreSQL 版本包括 9.6、10、11 和 12。对于 PostgreSQL 13.5 的支持可能存在一些问题。

    根据你提供的环境信息,你正在使用 Flink 1.16.1 和 Flink CDC 2.3.0,同时连接的是 PostgreSQL 13.5 数据库。在这种情况下,由于 Flink CDC 2.3.0 官方文档中没有明确提及对 PostgreSQL 13.5 的支持,因此出现报错是可能的。

    报错信息 "Could not initialize class io.debezium.embedded.EmbeddedEngine$EmbeddedConfig" 可能表示在加载 CDC 的配置时发生了问题。这可能与 Flink CDC 2.3.0 对 PostgreSQL 13.5 的兼容性有关。

    关于该问题,你可以尝试以下几点:

    1. 验证依赖版本:确认 Flink CDC 2.3.0 是否与其他依赖项(如 Debezium)的版本兼容。检查 Flink 和 Flink CDC 官方文档中推荐的依赖版本,并确保你的环境中符合要求。

    2. 提交 issue 报告:如果你确定使用的版本符合要求,且问题仍然存在,请提交一个 issue 报告到 Flink CDC Connectors 的 GitHub 页面(https://github.com/ververica/flink-cdc-connectors)。在报告中提供详细的环境信息、报错日志和复现步骤,这样开发者和社区成员可以更好地帮助你解决问题。

    另外,也可以尝试使用其他版本的 Flink CDC 或 PostgreSQL,以查看是否存在特定版本之间的兼容性问题。

    需要注意的是,Flink CDC 是一个活跃的开源项目,它的兼容性和支持范围可能会随着版本的更新而变化。因此,在选择和使用特定版本时,建议参考官方文档和社区讨论,并进行适当的测试和验证。

    2023-07-30 09:39:20
    赞同 展开评论 打赏

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

相关电子书

更多
搭建电商项目架构连接MySQL 立即下载
搭建4层电商项目架构,实战连接MySQL 立即下载
PolarDB MySQL引擎重磅功能及产品能力盛大发布 立即下载

相关镜像