private void createNewFetcher(InLongTopic topic) {
        if (!fetchers.containsKey(topic.getTopicKey())) {
            LOGGER.info("begin add Fetcher:{}", topic.getTopicKey());
            if (context != null) {
                context.addTopicOnlineCount(1);
                TopicFetcher fetcher = addTopic(topic);
                if (fetcher == null) {
                    fetchers.remove(topic.getTopicKey());
                    LOGGER.error("add fetcher error:{}", topic.getTopicKey());
                }
            } else {
                LOGGER.error("context == null or context.getStatManager() == null");
            }
        }
    }
online new inlong topic

@param newSubscribedInLongTopics List
@param reallyNewTopic List
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongSingleTopicManager.java