@Override
    public void close0() {
        if (Objects.nonNull(producer)) {
            try {
                producer.close();
                client.close();
            } catch (PulsarClientException e) {
                LOG.error("fail to close PulsarLogCollectClient, e", 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