??????????????????

Sun, 21 Jun 2020 22:11:56 -0700 

Hi


??????????????????????????????????????????????????????????????
????????????????????
1.????consumer????groupid??????????????????????????consumer??????????????????????????????????????????????????????????????????????????????flink????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????
2.????????????????oom??????????????????????????????????flink??????????????????????????????????????????????????????????????????????????????????????????????????????????flink??????????????????????????????????????????????????????????????????????????????????????
??????????
a.??????????
????kafka??500records/s??flink??????????????1000records/s??????flink 
job??????????????????????????????


b.????????oom??????????????????????????????????
????kafka??????1500records/s????????????????????????????????????????????????????????????????60??????flink??????1000records/s??????????????????????????????????????

??x ??flink??????????????????????????????????offset??????????????
1500 * 1 + 500 * (x - 1) = 1000 * x 
?????????? x = 2????
????????????????????????????kafka???????? * ????1???? + ????kafka???????? * 
????x - 1???? = flink ???????? * x????


????????flink??????????2????????????????????offset??
????????????????????????????????????flink??????????????????????????????????????????????????????????????????????????????????????2????????????2??????????????????????????????????????????????????????????????????????????????




------------------ ???????? ------------------
??????:&nbsp;"wangxiangyan"<[email protected]&gt;;
????????:&nbsp;2020??6??22??(??????) ????11:06
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re:????????????



??????????????????????????????????????????????????????????????????oom????????????????????????????????????????????kafka????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????
&amp;nbsp;
&amp;nbsp;
------------------&amp;nbsp;Original&amp;nbsp;------------------
From: &amp;nbsp;"Yichao Yang"<[email protected]&amp;gt;;
Date: &amp;nbsp;Mon, Jun 22, 2020 10:59 AM
To: &amp;nbsp;"user-zh"<[email protected]&amp;gt;; 

Subject: &amp;nbsp;??????????????????

&amp;nbsp;

Hi


??????????????????????????????????????????????????


Best,
Yichao Yang




------------------&amp;amp;nbsp;????????&amp;amp;nbsp;------------------
??????:&amp;amp;nbsp;"wangxiangyan"<[email protected]&amp;amp;gt;;
????????:&amp;amp;nbsp;2020??6??22??(??????) ????10:52
??????:&amp;amp;nbsp;"user-zh"<[email protected]&amp;amp;gt;;

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



hi??????????????????????????????????????????

回复