???????????????? ??????????????????kafka balance??????????PK??
????????????????????????????????????????????????????kafka 
partition??offset??????????????????????kafka 
balance????????????????????????????????????????????????





dixingxin...@163.com
 
???????? i'mpossible
?????????? 2020-04-22 17:14
???????? user-zh; zhisheng2018
?????? ?????? ??flink-connector-kafka??????????Subscribe????
Hi??
    
??????????????????????????????????????????????kafka??????????????????????????Flink??????????????????????????????????????????????????????kafka??rebalance??????????????????????????????
 
 
    
??????flink-connector-kafka????????????????????topic??????????????????????????????????????????????????????????????????????????????????????????kafka????????????????????????????????kafka
 checkpoint??????
 
 
    
????????????????????????????????????????????????????????????????????????????????
 
 
    ????????????????????????????????????
 
 
 
 
------------------ ???????? ------------------
??????:&nbsp;"zhisheng"<zhisheng2...@gmail.com&gt;;
????????:&nbsp;2020??4??22??(??????) ????9:02
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;
 
????:&nbsp;Re: ??flink-connector-kafka??????????Subscribe????
 
 
 
?????????????? group.id ????
 
i'mpossible <605769...@qq.com&gt; ??2020??4??21?????? ????6:12??????
 
&gt; Hi??
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Flink????Subscribe????????????connector??????
&gt; flink-connector-kafka-0.11_2.11??0.11x??
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 
??????????????????????????????TopicB????????????????????????????????Flink??????A??????????????group.id
&gt; ??????????TopicA????kafka????????????????????????????????
&gt;
&gt;
&gt;&nbsp;&nbsp;&nbsp;&nbsp; ??????????????
&gt;

回复