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

Flink CDC中postgresql参数里面没找到类似mysql里面这样的?不会没有吧?

Flink CDC中postgresql参数里面没找到类似mysql里面这样的?不会没有吧?

展开
收起
真的很搞笑 2023-10-04 07:42:44 82 0
2 条回答
写回答
取消 提交回答
  • Apache Flink CDC(Change Data Capture)支持多种数据库,包括PostgreSQL。在PostgreSQL中,你可以使用以下参数来配置CDC:

    cdc.source.postgres.user:设置PostgreSQL的用户名。
    cdc.source.postgres.password:设置PostgreSQL的密码。
    cdc.source.postgres.dbname:设置要捕获更改的数据库名。
    cdc.source.postgres.host:设置PostgreSQL服务器的主机名或IP地址。
    cdc.source.postgres.port:设置PostgreSQL服务器的端口号。
    

    这些参数与MySQL中的参数类似,但名称不同。例如,MySQL中的参数是cdc.source.mysql.user、cdc.source.mysql.password等。

    2023-10-12 17:49:22
    赞同 展开评论 打赏
  • 对不起,我之前的回答可能有误。Flink的CDC(Change Data Capture)功能确实支持PostgreSQL,但是在PostgreSQL中,并没有类似于MySQL的binlog或者row change log。因此,Flink的CDC功能无法直接从PostgreSQL捕获数据变化。

    如果你想从PostgreSQL全量复制数据,你可以使用Flink的DataStream API,并通过PostgreSQL的JDBC connector连接到数据库,然后使用CREATE TABLE AS SELECT语句来复制数据。

    如果你想从PostgreSQL捕获数据变化,你可能需要使用其他的工具或库,例如Debezium或者Lagouche MetaStore。这些工具或库可以从PostgreSQL捕获数据变化,并将这些变化发送到Kafka或者其他的消息队列。然后,你可以使用Flink的CDC connector从这些消息队列中捕获数据变化。

    2023-10-11 14:15:17
    赞同 展开评论 打赏

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

相关产品

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

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

    相关镜像