From 6bbfc3f50f895de8823901142fea60add35b94ea Mon Sep 17 00:00:00 2001
From: 0daypwn <30897509+0daypwn@users.noreply.github.com>
Date: Thu, 3 Nov 2022 21:08:24 +0800
Subject: [PATCH] [ISSUE #956]fix reset offset remove pq (#957)

---
 consumer/push_consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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)
 		}
 	}
 }