让我通过一个具体的FlinkSQL示例来展示Chunk分片的使用： -- 创建MySQL CDC源表，配置Chunk分片参数 CREATE TABLE source_table ( id INT, name STRING, age INT, PRIMARY KEY (id) NOT ENFORCED ) WITH ( 'connector' = 'mysql-cdc', 'hostname' = ...

代码示例如下： type DatabaseConfig struct { Host string `json:"host"` Port *int `json:"port"` // 自动生成的指针字段 } func main() { port := 5432 config := DatabaseConfig{Host: "localhost", Port: &port} ...