开发者社区> 问答> 正文

flink cdc读取Maxwell格式的binlog,如何获取表名等元信息?

请教下,看了这篇文章https://developer.aliyun.com/article/771438,flink-cdc 读取mysql Maxwell 格式binlog,怎么在flink 源表上获取mysql表名,通过这样的方式并没有生效 origin_table STRING METADATA FROM 'value.source.table' VIRTUAL,

https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/connectors/kafka.html

http://apache-flink.147419.n8.nabble.com/file/t572/lALPDg7mQSzBJifNAmzNBpY_1686_620.png*来自志愿者整理的flink

展开
收起
雪哥哥 2021-12-05 12:22:00 562 0
0 条回答
写回答
取消 提交回答
问答排行榜
最热
最新

相关电子书

更多
PolarDB-X 2.0 全局 Binlog 与备份恢复能 立即下载
基于 Flink SQL + Paimon 构建流式湖仓新方 立即下载
任庆盛|Flink CDC + Kafka 加速业务实时化 立即下载