FlinkKafkaProducer、StreamingFileSink的实现都支持Exactly-Once，可以研究下
Best Regards [email protected] > 2020年4月15日 上午11:00，阿华田 <[email protected]> 写道： > > 如果自定义具有Exactly-Once语义的sink，继承TwoPhaseCommitSinkFunction，怎么确保真正的Exactly-Once，大佬们有已经上线使用的案例demo吗？ > | | > 王志华 > | > | > [email protected] > | > 签名由网易邮箱大师定制 >
