@Override
    public void initClient0(@NonNull final PulsarLogCollectConfig.PulsarLogConfig config) {
        String topic = config.getTopic();
        String serviceUrl = config.getServiceUrl();
        if (StringUtils.isBlank(topic) || StringUtils.isBlank(serviceUrl)) {
            LOG.error("init PulsarLogCollectClient error, please check topic or serviceUrl.");
            return;
        }
        try {
            client = PulsarClient.builder().serviceUrl(serviceUrl).build();
            producer = client.newProducer().topic(topic).create();
            LOG.info("init PulsarLogCollectClient success.");
            Runtime.getRuntime().addShutdownHook(new Thread(this::close));

        } catch (PulsarClientException e) {
            LOG.error("init PulsarLogCollectClient error, ", e);
        }
    }
init producer.

@param config pulsar props
shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-pulsar/src/main/java/org/apache/shenyu/plugin/logging/pulsar/client/PulsarLogCollectClient.java