@Override
    public TypeInformation<Row> getProducedType() {
        DeserializationSchema<Row> deserializationSchema = deserializationMetricWrapper.getDeserializationSchema();
        return deserializationSchema.getProducedType();
    }
Reason:
Date: 2018/10/19
Company: www.dtstack.com

@author xuchao
kafka09/kafka09-source/src/main/java/com/dtstack/flink/sql/source/kafka/KafkaConsumer09.java