@Override
    public void open(Configuration configuration) throws Exception {
        LOG.info("--KafkaProducer011 open--");
        RuntimeContext runtimeContext = getRuntimeContext();
        serializationMetricWrapper.setRuntimeContext(runtimeContext);
        serializationMetricWrapper.initMetric();
        super.open(configuration);
    }
Reason:
Date: 2019/4/24
Company: www.dtstack.com

@author maqi
kafka11/kafka11-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/KafkaProducer011.java