public static void disablePullConsumption(DefaultLitePullConsumerWrapper wrapper, Set<String> topics) {
        Set<String> subscribedTopic = wrapper.getSubscribedTopics();
        if (subscribedTopic.stream().anyMatch(topics::contains)) {
            suspendPullConsumer(wrapper);
            return;
        }
        resumePullConsumer(wrapper);
    }
@Test
    public void testDisablePullConsumptionWithNoSubTractTopics() {
        subscribedTopics = new HashSet<>();
        subscribedTopics.add("test-topic-2");
        subscribedTopics.add("test-topic-3");
        pullConsumerWrapper.setSubscribedTopics(subscribedTopics);
        pullConsumerWrapper.setProhibition(true);
        pullConsumerWrapper.setSubscriptionType(SubscriptionType.SUBSCRIBE);
        RocketMqPullConsumerController.disablePullConsumption(pullConsumerWrapper, prohibitionTopics);
        Assert.assertFalse(pullConsumerWrapper.isProhibition());

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