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

???? Tue, 08 Sep 2020 04:09:10 -0700

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



| |
????
|
|
[email protected]
|
??????????????????????


??2020??09??8?? 18:24????????<[email protected]> ??????
??????????????????????????????????????????????????????????????????????????????????????????????????kafka????
????????????????????????????????????????????????????????????????????????????????????



&nbsp;




------------------&nbsp;????????&nbsp;------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2020??9??8??(??????) ????6:18
??????:&nbsp;"user-zh"<[email protected]&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;
 <[email protected]&amp;gt;;
????????:&amp;nbsp;2020??9??8??(??????) ????5:56
??????:&amp;nbsp;"user-zh"<[email protected]&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; ??????????????????????????

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

回复