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

Flink CDC地址结果都是相等的,为什么在flink 的JdbcOutputFormat 对象?

Flink CDC地址结果都是相等的 为什么在flink 的JdbcOutputFormat 对象中会对齐对象进行改变呢?比较像个变量中的地址是否相对不能用== 那用什么?同样的方式我用线程池测试 完全没有问题image.png

展开
收起
真的很搞笑 2023-09-28 11:53:43 68 0
1 条回答
写回答
取消 提交回答
  • Flink CDC 的地址结果都是相等的,是因为 Kafka 的 topic 是全局唯一的,所以 Kafka 的消费者可以通过 topic 来找到对应的生产者。

    JdbcOutputFormat 是 Flink 的一种数据输出格式,它可以将数据写入到关系型数据库中。当使用 JdbcOutputFormat 将数据写入到关系型数据库中时,需要指定数据库的连接信息,包括连接 URL、用户名和密码。

    如果数据库的连接信息没有指定,那么 JdbcOutputFormat 就会使用默认的连接信息,默认的连接信息是 jdbc:mysql://localhost:3306/test。

    如果您使用的是 Flink CDC,那么数据库的连接信息应该是 Kafka 的 topic,因为 Kafka 的 topic 是全局唯一的,所以 Kafka 的消费者可以通过 topic 来找到对应的生产者。

    如果您使用的是 JdbcOutputFormat,并且您没有指定数据库的连接信息,那么就会使用默认的连接信息,默认的连接信息是 jdbc:mysql://localhost:3306/test。

    如果您需要使用 Flink CDC 的数据写入到关系型数据库中,那么您需要在 Flink 的配置文件中指定数据库的连接信息。

    例如,以下是 Flink 的配置文件:

    jobmanager.memory.size: 1024m
    taskmanager.memory.size: 1024m

    connector.type: jdbc
    connector.path: jdbc:mysql://localhost:3306/test
    connector.username: root
    connector.password: root
    在上述配置文件中,connector.type 指定了数据输出格式,connector.path 指定了数据库的连接信息,connector.username 指定了用户名,connector.password 指定了密码。

    如果您使用的是 Flink CDC,那么您应该使用 connector.type: kafka,而不是 connector.type: jdbc。

    2023-10-12 11:37:22
    赞同 展开评论 打赏

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

相关产品

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

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