private void offlinePulsarClient(String clientId) {
        PulsarClient client = pulsarClients.remove(clientId);
        if (client != null) {
            LOGGER.info("start to close pulsar clientId={}", clientId);
            try {
                client.close();
                LOGGER.info("success to close pulsar clientId={}", clientId);
            } catch (Exception e) {
                LOGGER.warn("failed to close pulsar clientId={}", clientId);
            }
        } else {
            LOGGER.warn("when close pulsar 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