private void updateTopicRepo(Set<Integer> topicBrokerSet, List<Integer> allBrokerIdList,
            TopicTaskEntry topicTask) {
        if (!topicBrokerSet.containsAll(allBrokerIdList)) {
            Integer retryTimes = topicTask.getConfigRetryTimes() + 1;
            topicTask.setConfigRetryTimes(retryTimes);
            topicTaskRepository.save(topicTask);
        }
    }
Add topic info

@param clusterId this is the cluster id
@param topicTasks topic info
inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/executors/AddTopicExecutor.java