public <T extends OUT> PulsarSourceBuilder<T> setDeserializationSchema(
            GenericRecordDeserializer<T> deserializer) {
        return setDeserializationSchema(new GenericRecordDeserializationSchema<>(deserializer));
    }
Deserialize the messages from Pulsar by using {@link Schema#AUTO_CONSUME()}. It will turn the
pulsar message into a {@link GenericRecord} first. Using this method can consume the messages
with multiple schemas in the same topic.
inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java