??????
??????????pyflink??mysql-cdc????????????????????????????mysql??5.7
v????????????????binlog????????????????????
CREATE TABLE test (
id int,
name string,
age int,
PRIMARY KEY (id) NOT ENFORCED
) WITH (
'connector' = 'mysql-cdc',
'hostname' = '10.11.33.195',
'port' = '3306',
'username' = 'root',
'password' = 'ha@123',
'server-id' = '123',
'database-name' = 'mysql',
'table-name' = 'zk_test'
)
t_env.execute_sql('select id,name,age from test where id > 0').print()
????python????????????????????
??????????????????????????????????????????????????????????????????????????????????????
