diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
index 0ae779971c8..2771792188f 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
@@ -393,6 +393,11 @@ public void onSuccess(PullResult pullResult) {
                             break;
                         case NO_NEW_MSG:
                         case NO_MATCHED_MSG:
+                            if (pullRequest.getProcessQueue().isDropped()) {
+                                log.info("the message queue not be able to consume, because it's dropped. messageQueue={}",
+                                    pullRequest.getMessageQueue());
+                                return;
+                            }
                             pullRequest.setNextOffset(pullResult.getNextBeginOffset());
 
                             DefaultMQPushConsumerImpl.this.correctTagsOffset(pullRequest);