@Override
    public byte[] deserialize(String topic, Headers headers, byte[] data) {
        return toBytes(deserializer.deserialize(topic, headers, data));
    }
Date: 2021/04/20
Company: www.dtstack.com

@author tudou
kafka/kafka-source/src/main/java/com/dtstack/flink/sql/source/kafka/deserializer/DtKafkaDeserializer.java