@Override
    public RichSinkFunction<Tuple2<Boolean, Row>> createKafkaProducer(KafkaSinkTableInfo kafkaSinkTableInfo, TypeInformation<Tuple2<Boolean, Row>> typeInformation,
                                                                      Properties properties, Optional<FlinkKafkaPartitioner<Tuple2<Boolean, Row>>> partitioner, String[] partitionKeys) {
        return new KafkaProducer(kafkaSinkTableInfo.getTopic(), createSerializationMetricWrapper(kafkaSinkTableInfo, typeInformation), properties, partitioner, partitionKeys);
    }
company: www.dtstack.com

@author: toutian
create: 2019/12/24
kafka/kafka-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/KafkaProducerFactory.java