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 testDisablePullConsumptionWithAssignSubTractTopics() {
        subscribedTopics = new HashSet<>();
        subscribedTopics.add("test-topic-1");
        subscribedTopics.add("test-topic-2");
        pullConsumerWrapper.setSubscribedTopics(subscribedTopics);
        pullConsumerWrapper.setSubscriptionType(SubscriptionType.ASSIGN);
        pullConsumerWrapper.setAssignedMessageQueue(assignedMessageQueue);
        RocketMqPullConsumerController.disablePullConsumption(pullConsumerWrapper, prohibitionTopics);
        Mockito.verify(assignedMessageQueue, Mockito.times(1)).updateAssignedMessageQueue(
                Mockito.any());
    }