private void updateMetaData() {
        LOGGER.debug("InLongTopicManager doWork");
        if (stopAssign) {
            LOGGER.warn("assign is stopped");
            return;
        }
        // get sortTask conf from manager
        if (queryConsumeConfig != null) {
            long start = System.currentTimeMillis();
            context.addRequestManager();
            ConsumeConfig consumeConfig = queryConsumeConfig
                    .queryCurrentConsumeConfig(context.getConfig().getSortTaskId());
            if (consumeConfig != null) {
                this.assignedTopics = new HashSet<>(context.getConfig().getConsumerSubset(consumeConfig.getTopics()));
                handleUpdatedConsumeConfig();
            } else {
                LOGGER.warn("subscribedInfo is null");
                context.addRequestManagerFail(System.currentTimeMillis() - start);
            }
        } else {
            LOGGER.error("subscribedMetaDataInfo is null");
        }
    }
Inlong manager that maintain the single topic fetchers.
It is suitable to the cases that each topic has its own configurations.
And each consumer only consume the very one topic.
InlongMultiTopicManager was used since 1.9.0
inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongTopicManager.java