Flink CDC里这种数据 flinksql 该如何解析？

你直接写字段名字，flink会自动解析的。create table 表名(
id 数据类型,
name 数据类型,
date 数据类型
)CREATE TABLE product_view_mysql_kafka_parser(
id string,
name string,
age string
) WITH (
'connector' = 'kafka',
'topic' = test4',
'properties.bootstrap.servers' = '10.213.5.116:9093',
'scan.startup.mode' = 'earliest-offset',
'format' = 'json',
'properties.sasl.kerberos.service.name' = 'kafka'这样试试。还有一种可能就是解析sql不能直接用select *, select的时候需要对数组进行处理。 SqlServer CDC 连接器首先通过 JDBC 读取表中的历史数据，再从 change tables 中或缺增量变更数据，从而实现全增量同步。好像flink sqlsever cdc这个就可以满足需求。此回答来自钉群Flink CDC 社区。