flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "1193216154" <1193216...@qq.com>
Subject 回复:自定义具有Exactly-Once语义的sink
Date Wed, 15 Apr 2020 03:26:43 GMT
可以参考Flink 源码 FlinkKafkaProducer这个类




------------------&nbsp;原始邮件&nbsp;------------------
发件人:&nbsp;"阿华田"<a15733178518@163.com&gt;;
发送时间:&nbsp;2020年4月15日(星期三) 中午11:00
收件人:&nbsp;"user-zh@flink.apache.org"<user-zh@flink.apache.org&gt;;

主题:&nbsp;自定义具有Exactly-Once语义的sink



如果自定义具有Exactly-Once语义的sink,继承TwoPhaseCommitSinkFunction,怎么确保真正的Exactly-Once,大佬们有已经上线使用的案例demo吗?
| |
王志华
|
|
a15733178518@163.com
|
签名由网易邮箱大师定制
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message