Hi,all:
Flink??????????????????sink??mysql,ES????????????????exactly once??????? ????kafka????????sink??exactly once????,sink????????????. ????,??????mysql??????????????? ????. return new FlinkKafkaProducer011<>( "topic", new KeyedSerializationSchemaWrapper<>(new SimpleStringSchema()), producerProperties, FlinkKafkaProducer011.Semantic.EXACTLY_ONCE);