flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jinhai wang <jinhai...@gmail.com>
Subject Re: 自定义具有Exactly-Once语义的sink
Date Wed, 15 Apr 2020 03:27:28 GMT
FlinkKafkaProducer、StreamingFileSink的实现都支持Exactly-Once,可以研究下


Best Regards

jinhai.me@gmail.com

> 2020年4月15日 上午11:00,阿华田 <a15733178518@163.com> 写道:
> 
> 如果自定义具有Exactly-Once语义的sink,继承TwoPhaseCommitSinkFunction,怎么确保真正的Exactly-Once,大佬们有已经上线使用的案例demo吗?
> | |
> 王志华
> |
> |
> a15733178518@163.com
> |
> 签名由网易邮箱大师定制
> 


Mime
View raw message