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

Sat, 26 Sep 2020 00:41:34 -0700 

??????????????????????????????????????????ok??????????????????????????????????????????????????????????????????????????????????????????FlinkKafkaProducer????preCommit??????????KafkaProducer??flush??????????kafka??????????checkpoint????????????????????????????????????job??????????????????????????????????????????preCommit??????commit??????????????????????????????????????????????????????????




------------------ ???????? ------------------
??????: "????"<lingwang...@qq.com&gt;; 
????????: 2020??9??25??(??????) ????11:14
??????: "user-zh"<user-zh@flink.apache.org&gt;; 
????: ??????????????????



????????????????????????????????????preCommit??????????????????????????????????commit??????????????????????????????????


????????????????????????????commit??????????????????????????????????????????????????????????flink????????????state????????????????????????????????????source????????????????????????????????????????????????flink????????????????commit??????????


????????????????????????????????[??????]


????????????????commit????????????flink??????????????????????flink????????????????????????????????????????

回复