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

Flink CDC中db2的配置各位有没有弄过?

Flink CDC中db2的配置各位有没有弄过?将数据库表格配置为捕获模式

展开
收起
真的很搞笑 2023-09-28 10:09:59 151 0
1 条回答
写回答
取消 提交回答
  • Flink CDC 中 DB2 的配置如下:

    // 配置 Debezium
    debezium {
    // 连接 DB2 的配置
    database {
    connection.url = "jdbc:db2://localhost:50000/TEST"
    username = "db2admin"
    password = "123456"
    database.server.name = "DB2"
    database.history.kafka.bootstrap.servers = "localhost:9092"
    database.history.kafka.topic = "db2-history"
    }
    // 配置 Flink
    flink {
    parallelism = 1
    checkpoint.interval = 10000
    }
    }
    其中,database.connection.url 是 DB2 的连接 URL,username 和 password 是 DB2 的用户名和密码,database.server.name 是 DB2 的服务名,database.history.kafka.bootstrap.servers 是 Kafka 的地址,database.history.kafka.topic 是 Kafka 的主题。

    你可以根据自己的需要,修改上述配置。例如,如果你想配置多个 Kafka 地址,你可以将 database.history.kafka.bootstrap.servers 配置为一个逗号分隔的列表。

    2023-10-12 11:43:32
    赞同 展开评论 打赏

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

相关产品

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

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