Hi chen310. Canal 和 debezium 已经实现，Maxwell 还没有完成，可以关注下 https://issues.apache.org/jira/browse/FLINK-20926
chen310 <22221...@163.com> 于2021年4月8日周四 下午5:35写道： > 请教下，看了这篇文章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> > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >
