Flink CDC debezium有解析sql的文档吗？怎么调用呢？

解析sql直接用query可以，此回答整理自钉群“Flink CDC 社区”

Debezium 是一种开源库，用于实时监控数据库的变化并发送给 Flink。
要使用Debezium，您需要先在 Flink CDC 的 Flink SQL CLI 中配置 Debezium 连接器，并指定相关参数。以下是配置示例：

1. 在 Flink SQL CLI 中添加如下配置：

   CREATE TABLE debezium_source (
   ...
   )
   WITH (
   'connector' = 'jdbc',
   'url' = '...', -- JDBC URL of the MySQL database,
   'table-name' = '...',
   'username' = '...',
   'password' = '...',
   'topic.prefix' = '...'
   );
   

其中，url、table-name、username 和 password 为您的数据库信息；topic.prefix 为将要发送的消息的主题前缀。

1. 使用 Flink SQL API，添加 Debezium 连接器，并设置相关参数：

   INSERT INTO debezium_source SELECT * FROM debezium_source;
   

Debezium 连接器将解析数据库的变化，并将其发送给 Flink SQL API。