public static void checkTargetBrokersComplete(Set<String> targetBrokers, Map<String, TopicConfigAndQueueMapping> brokerConfigMap) {
        for (String broker : brokerConfigMap.keySet()) {
            if (brokerConfigMap.get(broker).getMappingDetail().getHostedQueues().isEmpty()) {
                continue;
            }
            if (!targetBrokers.contains(broker)) {
                throw new RuntimeException("The existed broker " + broker + " dose not in target brokers ");
            }
        }
    }
@Test(expected = RuntimeException.class)
    public void testTargetBrokersComplete() {
        String topic = "static";
        String broker1 = "broker1";
        String broker2 = "broker2";
        Set<String> targetBrokers = new HashSet<>();
        targetBrokers.add(broker1);
        Map<String, TopicConfigAndQueueMapping> brokerConfigMap = new HashMap<>();
        TopicQueueMappingDetail mappingDetail = new TopicQueueMappingDetail(topic, 0, broker2, 0);
        mappingDetail.getHostedQueues().put(1, new ArrayList<>());
        brokerConfigMap.put(broker2, new TopicConfigAndQueueMapping(new TopicConfig(topic, 0, 0), mappingDetail));
        TopicQueueMappingUtils.checkTargetBrokersComplete(targetBrokers, brokerConfigMap);
    }