[ISSUE apache#956]fix reset offset remove pq

0daypwn · Nov 3, 2022 · e61fc1d · e61fc1d
1 parent 92515f7
commit e61fc1d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)
 		}
 	}
 }