Flink CDC：使用 Flink SQL 将多表写入一个 Kafka Topic 以及 Flink 作业数量的测试

  • 开发
  • 14

本测试要验证两个问题：

  • Flink CDC 能否将多张表的 CDC 数据 （debezium-json 格式）写入到同一个 Kafka Topic 中？
  • 验证使用 Flink SQL 方式将多表同时写入 Kafka 时，Flink 的作业数量

首先，准备好用 Flink SQL 实现的将两张表同步到一个 Kafka Topic 中的代码：

create catalog mysql_datasource with (
    'type'='jdbc',
    'base-url'='jdbc:mysql://10.0.13.30:3306',
    'default-database'='gmall'
阅读全部

相关推荐

  1. Flink CDC：使用 Flink SQL 将多表写入一个 Kafka Topic 以及 Flink 作业数量的测试

    2024-04-21 08:00:01       15 阅读

  2. 【Flink-Sql-Kafka-To-ClickHouse】使用 FlinkSql 将 Kafka 数据写入 ClickHouse

    2024-04-21 08:00:01       32 阅读

  4. 【Flink】FlinkSQL的DataGen连接器（测试利器）

    2024-04-21 08:00:01       31 阅读

  5. flink: 使用table API 从kafka的一个分区读取数据并写入另一个分区

    2024-04-21 08:00:01       22 阅读

  6. 基于scala使用flink将kafka数据写入mysql示例

    2024-04-21 08:00:01       38 阅读

  7. FlinkSql一个简单的测试程序

    2024-04-21 08:00:01       26 阅读

  8. flink: 通过Sink将数据写入MySQL

    2024-04-21 08:00:01       25 阅读

  9. flink重温笔记（十八）： flinkSQL 顶层 API ——时态表实现表数据动态变化（涵盖全面实用的 API ）

    2024-04-21 08:00:01       18 阅读

最近更新

  4. TCP协议是安全的吗?

    2024-04-21 08:00:01       18 阅读

  12. 阿里云服务器执行yum，一直下载docker-ce-stable失败

    2024-04-21 08:00:01       19 阅读

  13. 【Python教程】压缩PDF文件大小

    2024-04-21 08:00:01       18 阅读

  18. 通过文章id递归查询所有评论（xml）

    2024-04-21 08:00:01       20 阅读

热门阅读

  6. Nginx基础（05）

    2024-04-21 08:00:01       16 阅读

  9. Python5种算法回溯+剪枝、字典序、递归交换、计数回溯、迭代法 实现全排列ll【力扣题47】

    2024-04-21 08:00:01       18 阅读

  10. 【架构】Elasticsearch+Logstash+Kibana架构

    2024-04-21 08:00:01       16 阅读

  11. CentOS常见的命令

    2024-04-21 08:00:01       22 阅读

  17. Git 将一个项目同时推送到多个远程仓库

    2024-04-21 08:00:01       41 阅读

  20. 使用策略模式实现 Spring 分布式和单机限流

    2024-04-21 08:00:01       13 阅读

  28. 笔记wife_assistant

    2024-04-21 08:00:01       14 阅读