public void addTopicFuture(TopicFuture future) {
        BlockingQueue<TopicFuture> tmpQueue = new LinkedBlockingQueue<>();
        BlockingQueue<TopicFuture> queue = pendingTopics.putIfAbsent(
                future.getEntry().getClusterId(), tmpQueue);
        if (queue == null) {
            queue = tmpQueue;
        }
        queue.add(future);
        if (queue.size() > queueWarningSize) {
            log.warn("queue size exceed {}, please check it", queueWarningSize);
        }
    }
add topic future to pending executing queue.
@param future - TopicFuture.
inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/service/TopicBackendWorker.java