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 testDisablePullConsumptionWithAssignNoSubTractTopics() {
        subscribedTopics = new HashSet<>();
        subscribedTopics.add("test-topic-2");
        Collection<MessageQueue> messageQueues = new ArrayList<>();
        MessageQueue messageQueue = new MessageQueue("test-topic-2", "broker-1", 1);
        messageQueues.add(messageQueue);
        pullConsumerWrapper.setMessageQueues(messageQueues);
        pullConsumerWrapper.setSubscribedTopics(subscribedTopics);
        pullConsumerWrapper.setSubscriptionType(SubscriptionType.ASSIGN);
        pullConsumerWrapper.setAssignedMessageQueue(assignedMessageQueue);
        RocketMqPullConsumerController.disablePullConsumption(pullConsumerWrapper, prohibitionTopics);
        Mockito.verify(pullConsumer, Mockito.times(1)).assign(
                Mockito.any());
    }