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

Thu, 11 Jun 2020 01:58:15 -0700 

>Hi
>????????????????????????
>????????????????exctly-once????????
>checkpoint????????????????????
>????????kafka????????????????????????????????????
>??????????????????






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

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



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


---
Best,
Matt Wang


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


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


Best,
Yichao Yang




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

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



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

回复