public void removeTopic(Set<String> topicSet) {
        for (String topic : topicSet) {
            if (topic == null) {
                continue;
            }
            AtomicInteger subCnt = publishTopics.get(topic);
            if (subCnt == null) {
                return;
            }
            if (subCnt.decrementAndGet() == 0) {
                publishTopics.remove(topic);
            }
        }
    }
Remove published topics. We will ignore null topics or non-published topics.

@param topicSet   the topic set need to delete
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/producer/ProducerManager.java