diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go
index da7ba921..e91bad01 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -965,7 +965,7 @@ func (pc *pushConsumer) ResetOffset(topic string, table map[primitive.MessageQue
 			}
 			pq := v.(*processQueue)
 			pc.removeUnnecessaryMessageQueue(mq, pq)
-			pc.processQueueTable.Delete(mq)
+			pc.processQueueTable.Delete(*mq)
 		}
 	}
 }