??????????????????????????????????????
????????????????????????????????????????????????
???????????????????
------------------ ???????? ------------------
??????:
"user-zh"
<yrx73...@163.com>;
????????: 2020??9??8??(??????) ????7:08
??????: "user-zh@flink.apache.org"<user-zh@flink.apache.org>;
????: ??????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; ??????????????????????????
