?????????????????????????? ????kafka??????????????????????flink??????????????????table_ddl ??????????'update-mode' = 'append'??????????kafka??????????????????????table_ddl??????????????????????????????????????kafka????????????????table_ddl??????????????????????????????????????????????????????????????????????????table_ddl??????????kafka??????????
table_ddl = """ CREATE TABLE table_ddl ( trck_id VARCHAR ) WITH ( 'connector.type' = 'kafka', 'connector.version' = 'universal', 'connector.topic' = 'w', 'connector.startup-mode' = 'group-offsets', 'connector.properties.group.id' = 'trck_w', 'update-mode' = 'append', 'connector.properties.zookeeper.connect' = '*', 'connector.properties.bootstrap.servers' = '%#', 'format.type' = 'json', 'format.derive-schema' = 'true' ) """
