@Override
    public boolean init() {
        return createConsumer(pulsarClient);
    }
create Consumer and fetch thread

@return boolean
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/pulsar/PulsarSingleTopicFetcher.java