??????flink????????GMV,??????????????????????????????

[????]

??????canal??????mysql??????????????????????????????????????????????????????????????????????


| |
????
|
|
yrx73...@163.com
|
??????????????????????


??2020??09??8?? 18:24????????<x...@chyjr.com> ??????
??????????????????????????????????????????????????????????????????????????????????????????????????kafka????
????????????????????????????????????????????????????????????????????????????????????



&nbsp;




------------------&nbsp;????????&nbsp;------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<so...@foxmail.com&gt;;
????????:&nbsp;2020??9??8??(??????) ????6:18
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;??????flink????????GMV,??????????????????????????????



????????????????????????flink??????update????????????????????
????????????????update????insert??
??????????????????????????????????????????????????????????????kafa????2????????
????1:009????&amp;nbsp; ??????-1000
????2:009????&amp;nbsp; ??????500


????flink????????????????????


------------------&amp;nbsp;????????&amp;nbsp;------------------
??????:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 
"user-zh"&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 <x...@chyjr.com&amp;gt;;
????????:&amp;nbsp;2020??9??8??(??????) ????5:56
??????:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;

????:&amp;nbsp;flink????????GMV,??????????????????????????????



??????
&amp;amp;nbsp; &amp;amp;nbsp;??????????????GMV,????????????????????????
&amp;amp;nbsp; 
??????????mysql,????binlog??????????????????kafka.??????kafka??????????????????????
&amp;amp;nbsp; ????????009 ????10??????????????1000. ????????json??????kafka 
,GMV??????????1000.
&amp;amp;nbsp; ????????15????009????????????????500??????????json????????kafka. 
??????????????????????????????????????????????????????&amp;amp;nbsp;&amp;amp;nbsp;
?????????????? update /delete 
??????????????????????????????????????????????????????????????????????????????????????????????


&amp;amp;nbsp; ??????????????????????????