flink-1.14.4kafka-2.4.0setTransactionalIdPrefix????????????????????????????????????job??????????????????????????ID????????????????????????????????????chk????????????????????????????ID????????????????????????????????????????????????????????????????System.currentTimeMillis()????????????ID??????????????????????????KafkaSink<String>
sink = KafkaSink.<String>builder()
.setBootstrapServers(BOOTSTRAP_SERVERS)
.setKafkaProducerConfig(kafkaProducerConfig)
.setTransactionalIdPrefix(JOB_NAME+System.currentTimeMillis()+"transactional.id")
.setRecordSerializer(KafkaRecordSerializationSchema.builder()
.setTopic(SINK_TOPICS)
.setValueSerializationSchema(new SimpleStringSchema())
.build())
.setDeliverGuarantee(DeliveryGuarantee.EXACTLY_ONCE)
.build();