各位大佬,flink cdc的tidb_cdc除了通过pd.address的连接方式之外,还有别的连接方式吗?可以通过db的方式连接吗?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
对于 Flink CDC 中的 TiDB CDC,除了使用 pd.address 连接方式连接到 PD(Placement Driver)节点外,还可以通过其他方式进行连接。TiDB CDC 提供了以下两种连接方式:
使用 Placement Driver 地址连接:这是最常见和推荐的方式,你需要指定 PD 的地址来与 TiDB 集群建立连接。在 Flink 的 CDC Connector 配置中,通过设置 pd.address 参数来指定 PD 的地址。
使用数据库连接方式连接:从 TiDB 4.0 版本开始,TiDB CDC 支持使用数据库的方式进行连接。你可以配置 sink.connection-url、sink.username 和 sink.password 参数来指定 TiDB 数据库的连接信息。但需要注意的是,这种连接方式目前仍然处于实验性阶段。
下面是使用数据库连接方式进行 TiDB CDC 配置的示例:
connector.name=cdc
connector.version=1.2.0
# ...
sink.connection-url=jdbc:mysql://<tidb_host>:<tidb_port>/<database>
sink.username=<username>
sink.password=<password>
其中 <tidb_host> 是 TiDB 的主机名或 IP 地址,<tidb_port> 是 TiDB 的端口号,<database> 是要连接的数据库名称。你还需要提供合适的用户名和密码。
。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。