public PulsarSourceBuilder<OUT> setPulsarCrypto(
            PulsarCrypto pulsarCrypto, ConsumerCryptoFailureAction action) {
        this.pulsarCrypto = checkNotNull(pulsarCrypto);
        configBuilder.set(PULSAR_CRYPTO_FAILURE_ACTION, action);
        return this;
    }
Sets a {@link PulsarCrypto}. Configure the key reader and keys to be used to encrypt the
message payloads.

@param pulsarCrypto PulsarCrypto object.
@return this PulsarSourceBuilder.
inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java