flinkcdc监听mysql表结构变化如何同步到postgre

用flinkcdc 3.0.0的mysql连接器监听了表的表结构变化

监听到的消息为

{"source":{"version":"1.9.7.Final","connector":"mysql","name":"mysql_binlog_source","ts_ms":1720082671720,"snapshot":"false","db":"test","sequence":null,"table":"test1","server_id":1,"gtid":null,"file":"binlog.000058","pos":736969985,"row":0,"thread":null,"query":null},"historyRecord":"{\"source\":{\"file\":\"binlog.000058\",\"pos\":736969985,\"server_id\":1},\"position\":{\"transaction_id\":null,\"ts_sec\":1720082671,\"file\":\"binlog.000058\",\"pos\":736970183,\"gtids\":\"9dab090a-a2f5-11ee-ad5f-00163e01dd9e:1-844113\",\"server_id\":1},\"databaseName\":\"test\",\"ddl\":\"alter table test.test1 ADD COLUMN age int(11)\",\"tableChanges\":[{\"type\":\"ALTER\",\"id\":\"\\\"test\\\".\\\"test1\\\"\",\"table\":{\"defaultCharsetName\":\"utf8mb4\",\"primaryKeyColumnNames\":[\"id\"],\"columns\":[{\"name\":\"id\",\"jdbcType\":4,\"typeName\":\"INT\",\"typeExpression\":\"INT\",\"charsetName\":null,\"position\":1,\"optional\":false,\"autoIncremented\":false,\"generated\":false,\"comment\":null,\"hasDefaultValue\":false,\"enumValues\":[]},{\"name\":\"name\",\"jdbcType\":12,\"typeName\":\"VARCHAR\",\"typeExpression\":\"VARCHAR\",\"charsetName\":\"utf8mb4\",\"length\":20,\"position\":2,\"optional\":true,\"autoIncremented\":false,\"generated\":false,\"comment\":null,\"hasDefaultValue\":true,\"enumValues\":[]},{\"name\":\"age\",\"jdbcType\":4,\"typeName\":\"INT\",\"typeExpression\":\"INT\",\"charsetName\":null,\"length\":11,\"position\":3,\"optional\":true,\"autoIncremented\":false,\"generated\":false,\"comment\":null,\"hasDefaultValue\":true,\"enumValues\":[]}]},\"comment\":null}]}"}

请问可以将这个表结构变化同步到postgre相同的表中吗？并且实时同步后续增加字段的数据，如果可以，请提供下实现思路及调用api