private void initConsumer() {
        LOG.info("init tube consumer, topic:{}, masterList:{}", topic, masterUrl);
        ConsumerConfig consumerConfig = new ConsumerConfig(masterUrl, mqConfig.getTubeConsumerGroupName());
        consumerConfig.setConsumePosition(ConsumePosition.CONSUMER_FROM_LATEST_OFFSET);
        try {
            sessionFactory = new TubeMultiSessionFactory(consumerConfig);
            pullConsumer = sessionFactory.createPullConsumer(consumerConfig);
            pullConsumer.subscribe(topic, null);
            pullConsumer.completeSubscribe();
        } catch (TubeClientException e) {
            LOG.error("init tube consumer error {}", e.getMessage());
        }

    }
Constructor
@param insertServiceList
@param storeConfig
@param mqConfig
inlong-audit/audit-store/src/main/java/org/apache/inlong/audit/store/service/consume/TubeConsume.java