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

Thu, 11 Jun 2020 01:59:30 -0700 

checkpoint????????????????????




------------------ ???????? ------------------
??????: "??????"<huyunchuan1...@foxmail.com&gt;; 
????????: 2020??6??11??(??????) ????4:56
??????: "user-zh"<user-zh@flink.apache.org&gt;; 
????: ??????flink??????????????????



&amp;gt;Hi
&amp;gt;????????????????????????
&amp;gt;????????????????exctly-once????????
&amp;gt;checkpoint????????????????????
&amp;gt;????????kafka????????????????????????????????????
&amp;gt;??????????????????






------------------&amp;nbsp;????????&amp;nbsp;------------------
??????:&amp;nbsp;"Matt Wang"<wang...@163.com&amp;gt;;
????????:&amp;nbsp;2020??6??10??(??????) ????7:39
??????:&amp;nbsp;"user-zh@flink.apache.org"<user-zh@flink.apache.org&amp;gt;;

????:&amp;nbsp;Re:flink??????????????????



kafka ?? 0.11.0 ?????????????????? flink ???????????? EXACTLY-ONCE?????????? 
send ?? kafka???????????? commit 
?????????????????????????????????????????????????? kafka 
??????????????????????????????????????????????????????????&amp;nbsp; 
isolation.level ???????????????????????? commit ????????


---
Best,
Matt Wang


On 06/10/2020 14:28??Yichao Yang<1048262...@qq.com&amp;gt; wrote??
Hi


sink&amp;amp;nbsp; 
??kafka????????kafka????????1.0??????kafka????????????????????????????????EXACTLY-ONCE????????????????????????????????


Best,
Yichao Yang




------------------&amp;amp;nbsp;????????&amp;amp;nbsp;------------------
??????:&amp;amp;nbsp;"??????"<huyunchuan1...@foxmail.com&amp;amp;gt;;
????????:&amp;amp;nbsp;2020??6??10??(??????) ????2:25
??????:&amp;amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;amp;gt;;

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



&amp;amp;amp;gt;Hi,
&amp;amp;amp;gt;??????flink??kafka??????????????????EXACTLY-ONCE??????
&amp;amp;amp;gt;??debug??????????????????????invoke????????traction.producer.send()??????????????????????????????????precommit??commit????
&amp;amp;amp;gt;??????????????????????????????

回复