is there some flag that help me get the primary key in output

[foobarrer]

I use flink cdc in copy the mysql data from one to another, what I want is tell me which column is the primary key in the output. So I can use the primary key to update and delete the data。

[Kyofin]

I want to get the primary key from playload too....

[foobarrer]

I really appreciate it if someone can tell me wether there is a primary key flagin the future or there will not have a primary key flag. I'm waiting for a certain answer, no matter whether it's true or false. thanks a lot

[ruanhang1993]

This information should be known before the job starts. And we do not need to pass it when reading data. If it is DataStream job, you may be able to pass it after the deserialization. But we can not do it in flink sql.

[PatrickRen]

Closing this issue because it was created before version 2.3.0 (2022-11-10). Please try the latest version of Flink CDC to see if the issue has been resolved. If the issue is still valid, kindly report it on Apache Jira under project Flink with component tag Flink CDC. Thank you!