flink sql 1.11 kafka cdc??holo sink

Tue, 08 Dec 2020 19:32:43 -0800 

flink sql 1.11 ????kafka source ?? ??kafka??????canal??????mysql ??????'format' 
= 'canal-json'?? ?????? 
1????source????????????msyql??????schema????????????????data[{}]??????????????????????table??ts??????????????
 2??????????topic????????mysql binlog??????????kafka 
source??????????????????????schema?????????? 3??????source??????holo sink 
????????????????delete??????????????holo??????????????????'ignoreDelete' = 
'false'

回复