public static void disablePushConsumption(DefaultMqPushConsumerWrapper wrapper, Set<String> topics) {
        Set<String> subscribedTopic = wrapper.getSubscribedTopics();
        if (subscribedTopic.stream().anyMatch(topics::contains)) {
            suspendPushConsumer(wrapper);
            return;
        }
        resumePushConsumer(wrapper);
    }
@Test
    public void testDisablePullConsumptionWithNoSubTractTopics() {
        subscribedTopics = new HashSet<>();
        subscribedTopics.add("test-topic-2");
        subscribedTopics.add("test-topic-3");
        pushConsumerWrapper.setSubscribedTopics(subscribedTopics);
        pushConsumerWrapper.setProhibition(true);
        RocketMqPushConsumerController.disablePushConsumption(pushConsumerWrapper, prohibitionTopics);
        Assert.assertFalse(pushConsumerWrapper.isProhibition());

        // 恢复消费后，再次下发禁消费配置
        MQClientInstance clientFactory = pushConsumerWrapper.getClientFactory();
        Mockito.reset(clientFactory);
        RocketMqPushConsumerController.disablePushConsumption(pushConsumerWrapper, prohibitionTopics);
        Mockito.verify(clientFactory, Mockito.times(0))
                .registerConsumer(Mockito.any(), Mockito.any());
    }