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 testDisablePullConsumptionNoTopic() {
        pullConsumerWrapper.setProhibition(true);
        pullConsumerWrapper.setSubscribedTopics(new HashSet<>());
        pullConsumerWrapper.setSubscriptionType(SubscriptionType.SUBSCRIBE);
        RocketMqPullConsumerController.disablePullConsumption(pullConsumerWrapper, prohibitionTopics);
        Assert.assertFalse(pullConsumerWrapper.isProhibition());
    }