private PulsarClient initPulsarClient(String pulsarUrl) throws Exception {
        PulsarClient pulsarClient = null;
        ClientBuilder builder = PulsarClient.builder();
        if (pulsarEnableTokenAuth && StringUtils.isNotEmpty(pulsarTokenAuth)) {
            builder.authentication(AuthenticationFactory.token(pulsarTokenAuth));
        }
        pulsarClient = builder.serviceUrl(pulsarUrl)
                .connectionTimeout(clientOpTimeout, TimeUnit.SECONDS).build();

        return pulsarClient;
    }
If this function is called successively without calling {@see #destroyConnection()}, only the
first call has any effect.

@throws FlumeException if an RPC client connection could not be opened
inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/pulsar/PulsarClientService.java