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

各位大神请教下Debezium格式有没有 canal 格式类似 canal-json.t

各位大神请教下Debezium格式有没有 canal 格式类似 canal-json.table.include 这个参数去过滤表的？

展开

收起

云上静思 2022-11-09 15:57:12 566 版权

1 条回答

写回答

取消提交回答

云墩墩

亲测tidb所产生的canal-json，flink消费kafka时，一旦加上这两个参数 'canal-json.database.include' = 'my_database', 'canal-json.table.include' = 'my_table',

那么将无法获取到数据，即select *即不报错也无数据。

此答案来自钉钉群“【2】Apache Flink China 社区”

2022-11-09 17:44:43

赞同展开评论

问答分类：

canal 实时计算 Flink版

问答标签：

格式JSON canal JSON debezium JSON

问答地址：

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

相关问答

实时计算 Flink版

flink sql如何过滤掉kafka topic中canal json格式的delete类型数据？

589

在Flink CDC中生成的canal 格式的json里面怎么让添加库名和表名信息？

在Flink CDC中flink cdc 3.1.0支持消费canal json数据吗？

Flink CDC中debezium采集的原始json数据能自定义吗？

252

flink cdc 3.x接kafka canal json数据源还不支持吗？

123

Flink CDC使用的是kafka canal json作为数据变更源，cdc3.0未来会支持么？

Flink CDC中话说debezium json中能够获取表的主键吗？

224

Flink CDC中mysql-cdc默认序列化反序列化binlog为debezium json吗？

134

内嵌的canal不支持mysql5.7 json类型

117

Flink CDC中这里除了支持有支持canal json吗!大佬们都用的什么版本啊？

101

大数据与机器学习

实时计算 Flink

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

我要提问

收录在圈子:

阿里云实时计算Flink

199211

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。