??????????????????flink ????????????????????????kafka,mysql??

2021-03-14 文章 Asahi Lee 
??
   ??flink 
??

??????????: Re: Flink????Kafka??Mysql?? End-To-End Exactly-Once????????????

2020-08-02 文章 ?????? 
MySQL??Connection??
??Connection A T ??commit()Connection 
A??A TwoPhaseCommitSinkFunction 
pendingCommitTransactions??Connection 
BcommitT


??MySQL??2PC??





----
??: 
   "user-zh"

https://github.com/lusecond/flink_help --depth=1
 gt;
 gt;
 gt; 
TwoPhaseCommitSinkFunction4??beginTransaction??preCommit??commit??abort
 gt; 
jdbc

?????? Flink????Kafka??Mysql?? End-To-End Exactly-Once????????????

2020-01-02 文章 ????2008 
??1??mysql-connector-java??latest
??5.1.6??
5.1.48
https://github.com/lusecond/flink_help --depth=1


 
TwoPhaseCommitSinkFunction4??beginTransaction??preCommit??commit??abort
 
jdbc