flink_cdc
flink +debezium Benchao Li-2??
----
??: "silence"http://apache-flink.147419.n8.nabble.com/
??1?
??1.11+??sqlupdate_beforeupdate_after?
???Flinkafter??before??
.
----
??:
O(??_??)O??
----
??:
"user-zh"
??
???
----
??:
"user-zh"
??canal??mysql??
| |
|
|
yrx73...@163.com
|
??
??2020??09??8?? 18:24 ??
??kafka
??kafka
----
??:
flink??update
updateinsert??
??kafa2
1:009 ??-1000
2:009 ??500
flink
??
??GMV,
??mysql,binlog??kafka.??kafka??
009 10??1000. json??kafka
,GMV??1000.
15009500??jsonkafka.
