Re: 【Flink在sink端的Exactly once语义】

[Benchao Li]

看起来现在只有Kafka实现了TwoPhaseCommitSinkFunction，所以目前应该也只有Kafka支持exactly once。

不过像Mysql、ES这种，可以根据主键来更新的，只要能做到at least once应该就可以了。

忝忝向仧 <153488...@qq.com> 于2020年6月21日周日 下午11:27写道：

> Hi,all:
>
>
> Flink连接器这块，如果是sink到mysql,ES等，有对应的实现exactly once语义么?
> 比如kafka的连接有sink的exactly once语义,sink时候指定即可.
> 那么,如果是mysql后者其他的有么?
> 谢谢.
> return new FlinkKafkaProducer011<&gt;(
>         "topic",
>         new KeyedSerializationSchemaWrapper<&gt;(new SimpleStringSchema()),
>         producerProperties,
>         FlinkKafkaProducer011.Semantic.EXACTLY_ONCE);



-- 

Best,
Benchao Li