@Override
    public void start() {
        String pulsarUrl = mqConfig.getPulsarServerUrl();
        Preconditions.checkArgument(StringUtils.isNotEmpty(pulsarUrl), "no pulsar server url specified");
        Preconditions.checkArgument(StringUtils.isNotEmpty(mqConfig.getPulsarTopic()),
                "no pulsar topic specified");
        Preconditions.checkArgument(StringUtils.isNotEmpty(mqConfig.getPulsarConsumerSubName()),
                "no pulsar consumeSubName specified");
        PulsarClient pulsarClient = getOrCreatePulsarClient(pulsarUrl);
        updateConcurrentConsumer(pulsarClient);
    }
Constructor
@param insertServiceList
@param storeConfig
@param mqConfig
inlong-audit/audit-store/src/main/java/org/apache/inlong/audit/store/service/consume/PulsarConsume.java