[ISSUE #956]fix reset offset remove pq (#957)

apache · Nov 3, 2022 · 6bbfc3f · 6bbfc3f
1 parent 96f00c4
commit 6bbfc3f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 		}
 	}
 }