From e61fc1df9a0a65651a177bf9681250da0c2b0434 Mon Sep 17 00:00:00 2001
From: 0daypwn <289785153@qq.com>
Date: Thu, 3 Nov 2022 17:56:49 +0800
Subject: [PATCH] [ISSUE #956]fix reset offset remove pq

---
 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 e81d4efc..3c94c4b5 100644
--- a/consumer/push_consumer.go
+++ b/consumer/push_consumer.go
@@ -944,7 +944,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)
 		}
 	}
 }