Flink CDC地址结果都是相等的 为什么在flink 的JdbcOutputFormat 对象中会对齐对象进行改变呢?比较像个变量中的地址是否相对不能用== 那用什么?同样的方式我用线程池测试 完全没有问题
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。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。