??Flink??sink????Exactly once??????

[????????]

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);