hi:
??????????
pyflink??1.12.0v????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????????????????????
+----+-------------+--------------------------------+-------------+
| op | id |
name |
age |
+----+-------------+--------------------------------+-------------+
Apr 15, 2021 2:27:15 PM com.github.shyiko.mysql.binlog.BinaryLogClient connect
INFO: Connected to 10.11.33.195:3306 at mysql-bin.000001/10303 (sid:123,
cid:87)
????mysql????zk_test??????????????????????????????????????????????????????????????????????????
lib?????????????????? connector.jar ??
