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