@Override
    public TopicFetcher removeTopic(InLongTopic topic, boolean closeFetcher) {
        TopicFetcher result = fetchers.remove(topic.getTopicKey());
        if (result != null && closeFetcher) {
            result.close();
        }
        return result;
    }
create fetcher (pulsar,tube,kafka)

@param topic {@link InLongTopic}
@return {@link TopicFetcher}
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongSingleTopicManager.java