private byte[] toBytes(T value){
        if(value instanceof byte[]){
            return  (byte[])value;
        }else{
            try {
                return this.objectMapper.readValue(this.objectMapper.writeValueAsBytes(value), String.class).getBytes(StandardCharsets.UTF_8);
            } catch (IOException e) {
                throw new SerializationException("Can't deserialize data", e);
            }
        }
    }
T value to byte[]
@param value
@return
kafka/kafka-source/src/main/java/com/dtstack/flink/sql/source/kafka/deserializer/DtKafkaDeserializer.java