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

Flink CDC中databaseList这个没问题,为什么?

Flink CDC中databaseList这个没问题,我会根据egenie_cloud_wms.拿到前面的egenie_cloud_wms,tableList就是egenie_cloud_wms.

展开
收起
真的很搞笑 2023-12-10 20:53:05 36 0
2 条回答
写回答
取消 提交回答
  • 在Flink CDC中,databaseList用于指定要捕获的数据库列表。如果你想要获取egenie_cloud_wms数据库中的表列表,你需要将egenie_cloud_wms作为databaseList的一个元素。

    例如,你可以这样设置:

    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
    env.setParallelism(1);
    
    // 创建Flink CDC Source连接器
    DebeziumSource<String> source = new DebeziumSource<>(
        "mysql-cdc", // 使用的CDC connector名称
        "localhost:3306", // MySQL服务器地址和端口
        "username", // MySQL用户名
        "password", // MySQL密码
        "dbname", // 要连接的数据库名
        "tablename", // 要捕获的表名
        new DatabaseHistory(), // 用于存储数据库历史记录的对象
        new DebeziumProperties.Builder() // 配置Debezium连接器的属性
            .databaseHistoryClassName("org.apache.flink.connector.debezium.history.DatabaseHistory")
            .build());
    
    source.addSink(new FlinkKafkaConsumer<>("topic", new SimpleStringSchema(), properties));
    
    env.execute("Flink CDC Example");
    

    在这个例子中,我们创建了一个DebeziumSource连接器,指定了要连接的MySQL服务器、用户名、密码、数据库名和表名。然后,我们将这个连接器添加到一个Flink Kafka消费者中,以便将捕获到的数据发送到指定的Kafka主题。

    2023-12-11 16:35:25
    赞同 展开评论 打赏
  • 我建议先可视化写测试一下,不要用方法调用 ,此回答整理自钉群“Flink CDC 社区”

    2023-12-11 11:58:06
    赞同 展开评论 打赏

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

相关产品

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

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