private void offlineTubeFactory(String clientId) {
        TubeConsumerCreator client = tubeFactories.remove(clientId);
        if (client != null) {
            LOGGER.info("start to close tube clientId={}", clientId);
            try {
                client.getMessageSessionFactory().shutdown();
                LOGGER.info("success to close tube clientId={}", clientId);
            } catch (Exception e) {
                LOGGER.warn("failed to close tube clientId={}", clientId);
            }
        } else {
            LOGGER.warn("when close tube client, find no client id={}", clientId);
        }
    }
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