diff --git a/defibus-client/src/main/java/com/webank/defibus/consumer/DeFiBusPushConsumer.java b/defibus-client/src/main/java/com/webank/defibus/consumer/DeFiBusPushConsumer.java
index 4130d66..ac266f5 100644
--- a/defibus-client/src/main/java/com/webank/defibus/consumer/DeFiBusPushConsumer.java
+++ b/defibus-client/src/main/java/com/webank/defibus/consumer/DeFiBusPushConsumer.java
@@ -169,6 +169,7 @@ public void unsubscribe(String topic, boolean isNeedSendHeartbeat) {
             ProcessQueue pq = entry.getValue();
             if (messageQueue.getTopic().equals(topic)) {
                 pq.setDropped(true);
+                this.getDefaultMQPushConsumer().getDefaultMQPushConsumerImpl().getOffsetStore().persist(messageQueue);
             }
         }
         this.defaultMQPushConsumer.unsubscribe(topic);