开发者社区> 问答> 正文

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 22:24:25 778 0
1 条回答
写回答
取消 提交回答
  • Canal 和 debezium 已经实现,Maxwell 还没有完成,可以关注下 https://issues.apache.org/jira/browse/FLINK-20926*来自志愿者整理的flink

    2021-12-05 22:40:53
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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