各位大佬,flink cdc的tidb_cdc除了通过pd.address的连接方式之外,还有别的?

各位大佬,flink cdc的tidb_cdc除了通过pd.address的连接方式之外,还有别的连接方式吗?可以通过db的方式连接吗?

展开
收起
真的很搞笑 2023-07-31 14:00:50 225 分享 版权
1 条回答
写回答
取消 提交回答
  • 对于 Flink CDC 中的 TiDB CDC,除了使用 pd.address 连接方式连接到 PD(Placement Driver)节点外,还可以通过其他方式进行连接。TiDB CDC 提供了以下两种连接方式:

    1. 使用 Placement Driver 地址连接:这是最常见和推荐的方式,你需要指定 PD 的地址来与 TiDB 集群建立连接。在 Flink 的 CDC Connector 配置中,通过设置 pd.address 参数来指定 PD 的地址。

    2. 使用数据库连接方式连接:从 TiDB 4.0 版本开始,TiDB CDC 支持使用数据库的方式进行连接。你可以配置 sink.connection-urlsink.usernamesink.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> 是要连接的数据库名称。你还需要提供合适的用户名和密码。

    2023-07-31 22:17:27
    赞同 展开评论

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

还有其他疑问?
咨询AI助理