public <T extends OUT> PulsarSourceBuilder<T> setDeserializationSchema(
            DeserializationSchema<T> deserializationSchema) {
        return setDeserializationSchema(
                new PulsarDeserializationSchemaWrapper<>(deserializationSchema));
    }
Deserialize messages from Pulsar by using the flink's {@link DeserializationSchema}. It would
consume the pulsar message as a byte array and decode the message by using flink's logic.
inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java