You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 1193216154 <11...@qq.com> on 2020/04/15 03:26:43 UTC
回复：自定义具有Exactly-Once语义的sink
可以参考Flink 源码 FlinkKafkaProducer这个类
------------------ 原始邮件 ------------------
发件人: "阿华田"<a15733178518@163.com>;
发送时间: 2020年4月15日(星期三) 中午11:00
收件人: "user-zh@flink.apache.org"<user-zh@flink.apache.org>;
主题: 自定义具有Exactly-Once语义的sink
如果自定义具有Exactly-Once语义的sink，继承TwoPhaseCommitSinkFunction，怎么确保真正的Exactly-Once，大佬们有已经上线使用的案例demo吗？
| |
王志华
|
|
a15733178518@163.com
|
签名由网易邮箱大师定制