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

[chen310]

请教下，看了这篇文章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/

[Qishang Zhong]

Hi chen310.
Canal 和 debezium 已经实现，Maxwell 还没有完成，可以关注下
https://issues.apache.org/jira/browse/FLINK-20926

chen310 <[hidden email]> 于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/
>

[chen310]

好的，感谢



--
Sent from: http://apache-flink.147419.n8.nabble.com/